vim-account and sdn support.

[osm/RO.git] / lcm / osm_common / msgbase.py

diff --git a/lcm/osm_common/msgbase.py b/lcm/osm_common/msgbase.py
index 745df7f..25e8c80 100644 (file)
--- a/lcm/osm_common/msgbase.py
+++ b/lcm/osm_common/msgbase.py
@@ -1,6 +1,9 @@
 
+import asyncio
 from http import HTTPStatus
 
+__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
+
 
 class MsgException(Exception):
     """
@@ -14,7 +17,7 @@ class MsgException(Exception):
         :param http_code: <http.HTTPStatus> type. It contains ".value" (http error code) and ".name" (http error name
         """
         self.http_code = http_code
-        Exception.__init__(self, message)
+        Exception.__init__(self, "messaging exception " + message)
 
 
 class MsgBase(object):
@@ -28,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