bugfix
This commit is contained in:
parent
139e344d23
commit
3b5c2cf836
@ -43,7 +43,7 @@ async def run_zmq_proxy(app):
|
|||||||
task.cancel()
|
task.cancel()
|
||||||
|
|
||||||
async def msg_handler(msgstr):
|
async def msg_handler(msgstr):
|
||||||
debug('get message:{msgstr}')
|
debug(f'get message:{msgstr}')
|
||||||
msg = DictObject(**json.loads(msgstr))
|
msg = DictObject(**json.loads(msgstr))
|
||||||
ret = {
|
ret = {
|
||||||
"msgtype": "text", # 要返回的消息类型
|
"msgtype": "text", # 要返回的消息类型
|
||||||
@ -54,7 +54,7 @@ async def msg_handler(msgstr):
|
|||||||
|
|
||||||
async def woa_msghande():
|
async def woa_msghande():
|
||||||
config = getConfig()
|
config = getConfig()
|
||||||
debug('woa_msghander on({config.woa_handler_id}) starting ....')
|
debug(f'woa_msghander on({config.woa_handler_id}) starting ....')
|
||||||
await zmq_subscribe(config.woa_handler_id, msg_handler)
|
await zmq_subscribe(config.woa_handler_id, msg_handler)
|
||||||
debug('woa_msghandler stopped.................')
|
debug('woa_msghandler stopped.................')
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user