X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=lcm%2Fosm_common%2Fmsgbase.py;h=25e8c8097a3c111de18418f1f39735cef402debc;hb=f3a5443bfaf65f22540eff98a49be087f0479424;hp=a1054146071c05d8379d5ec5eca6730f5165c049;hpb=ae501920e1c0e03c8571bece610dd5518e6e86b9;p=osm%2FRO.git

diff --git a/lcm/osm_common/msgbase.py b/lcm/osm_common/msgbase.py
index a1054146..25e8c809 100644
--- a/lcm/osm_common/msgbase.py
+++ b/lcm/osm_common/msgbase.py
@@ -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