This commit is contained in:
yumoqing 2026-03-03 17:30:59 +08:00
parent 0cdf3c5fc8
commit 8399a28838
2 changed files with 2 additions and 3 deletions

View File

@ -11,7 +11,7 @@ from ahserver.filestorage import FileStorage
from ahserver.serverenv import ServerEnv from ahserver.serverenv import ServerEnv
from appPublic.dictObject import DictObject from appPublic.dictObject import DictObject
from appPublic.log import debug, exception, error from appPublic.log import debug, exception, error
from appPublic.zmqapi import zmq_subcribe, zmq_publish from appPublic.zmqapi import zmq_subscribe, zmq_publish
from appPublic.uniqueID import getID from appPublic.uniqueID import getID
from appPublic.jsonConfig import getConfig from appPublic.jsonConfig import getConfig
@ -182,7 +182,7 @@ class WOAHandler:
) )
return rzt_dic return rzt_dic
await zmq_publish(config.woa_handler_id, json.dumps(msg, ensure_ascii=False)) await zmq_publish(config.woa_handler_id, json.dumps(msg, ensure_ascii=False))
result = await zmq_subcribe(msg.subscribe_id) result = await zmq_subscribe(msg.subscribe_id)
rzt_dic = DictObject(**json.loads(result)) rzt_dic = DictObject(**json.loads(result))
return rzt_dic return rzt_dic

View File

@ -7,7 +7,6 @@ from ahserver.configuredServer import add_cleanupctx
from ahserver.serverenv import ServerEnv from ahserver.serverenv import ServerEnv
from appPublic.dictObject import DictObject from appPublic.dictObject import DictObject
from appPublic.log import debug, exception, error from appPublic.log import debug, exception, error
from appPublic.zmqapi import zmq_subcribe, zmq_publish
from appPublic.uniqueID import getID from appPublic.uniqueID import getID
from appPublic.jsonConfig import getConfig from appPublic.jsonConfig import getConfig