This commit is contained in:
yumoqing 2026-03-03 17:17:48 +08:00
parent 3b5c2cf836
commit 94a087758f

View File

@ -5,7 +5,7 @@ import argparse
from appPublic.log import MyLogger, info, debug, warning from appPublic.log import MyLogger, info, debug, warning
from appPublic.folderUtils import ProgramPath from appPublic.folderUtils import ProgramPath
from appPublic.jsonConfig import getConfig from appPublic.jsonConfig import getConfig
from appPublic.zmqapi import run_proxy from appPublic.zmqapi import run_proxy, zmq_subscribe
from appPublic.registerfunction import RegisterFunction from appPublic.registerfunction import RegisterFunction
from bricks_for_python.init import load_pybricks from bricks_for_python.init import load_pybricks
from ahserver.webapp import webapp from ahserver.webapp import webapp
@ -55,7 +55,10 @@ async def msg_handler(msgstr):
async def woa_msghande(): async def woa_msghande():
config = getConfig() config = getConfig()
debug(f'woa_msghander on({config.woa_handler_id}) starting ....') debug(f'woa_msghander on({config.woa_handler_id}) starting ....')
try:
await zmq_subscribe(config.woa_handler_id, msg_handler) await zmq_subscribe(config.woa_handler_id, msg_handler)
except Exception as e:
debug(f'Exception:{e}')
debug('woa_msghandler stopped.................') debug('woa_msghandler stopped.................')
def init(): def init():