projects
/
osm
/
RO.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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
from http import HTTPStatus
+__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
+
class MsgException(Exception):
"""
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
: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):
class MsgBase(object):
@@
-28,12
+31,17
@@
class MsgBase(object):
def connect(self, config):
pass
def connect(self, config):
pass
- def
write(self, msg
):
+ def
disconnect(self
):
pass
pass
- def
read(self
):
+ def
write(self, topic, key, msg
):
pass
pass
- def
disconnect(self
):
+ def
read(self, topic
):
pass
pass
+ async def aiowrite(self, topic, key, msg, loop):
+ pass
+
+ async def aioread(self, topic, loop):
+ pass