X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Fengine.py;h=b90f713426f0a7b1791b3c52f0bd3a54836dbd47;hp=f186a4c34caade844f5f8835e141f2c8b16d506d;hb=932499c09d729d235ccd1fc002156b8b23e9f165;hpb=0ea204e937146ae5fadfbb70fcd2619463359ffa

diff --git a/osm_nbi/engine.py b/osm_nbi/engine.py
index f186a4c..b90f713 100644
--- a/osm_nbi/engine.py
+++ b/osm_nbi/engine.py
@@ -28,7 +28,7 @@ from os import urandom
 from threading import Lock
 
 __author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
-min_common_version = "0.1.8"
+min_common_version = "0.1.16"
 
 
 class Engine(object):
@@ -98,7 +98,7 @@ class Engine(object):
                     self.msg.connect(config["message"])
                 else:
                     raise EngineException("Invalid configuration param '{}' at '[message]':'driver'".format(
-                        config["storage"]["driver"]))
+                        config["message"]["driver"]))
 
             self.write_lock = Lock()
             # create one class per topic
@@ -113,8 +113,8 @@ class Engine(object):
                 self.db.db_disconnect()
             if self.fs:
                 self.fs.fs_disconnect()
-            if self.fs:
-                self.fs.fs_disconnect()
+            if self.msg:
+                self.msg.disconnect()
             self.write_lock = None
         except (DbException, FsException, MsgException) as e:
             raise EngineException(str(e), http_code=e.http_code)