+import asyncio
from http import HTTPStatus
+__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
+
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):
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