Allow ns-creation params: vim-network, multisite deployement
[osm/NBI.git] / osm_nbi / msgbase.py
index a105414..25e8c80 100644 (file)
@@ -1,4 +1,5 @@
 
+import asyncio
 from http import HTTPStatus
 
 __author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
@@ -30,12 +31,17 @@ class MsgBase(object):
     def connect(self, config):
         pass
 
-    def write(self, msg):
+    def disconnect(self):
         pass
 
-    def read(self):
+    def write(self, topic, key, msg):
         pass
 
-    def disconnect(self):
+    def read(self, topic):
         pass
 
+    async def aiowrite(self, topic, key, msg, loop):
+        pass
+
+    async def aioread(self, topic, loop):
+        pass