pandajedi/jediorder/JediMsgProcessor.py

0001 from pandacommon.pandalogger import logger_utils
0002 from pandacommon.pandamsgbkr import msg_processor
0003
0004 from pandajedi.jediconfig import jedi_config
0005
0006 msg_processor.base_logger = logger_utils.setup_logger("JediMsgProcessor")
0007
0008
0009 # Main message processing agent
0010 class MsgProcAgent(msg_processor.MsgProcAgentBase):
0011     pass
0012
0013
0014 # launch
0015 def launcher(stop_event):
0016     tmp_log = logger_utils.make_logger(msg_processor.base_logger, method_name="launcher")
0017     tmp_log.debug("start")
0018     try:
0019         config_file = jedi_config.msgprocessor.configFile
0020     except Exception as e:
0021         tmp_log.error(f"failed to read config json file; should not happen... {e.__class__.__name__}: {e}")
0022         raise e
0023     # start
0024     agent = MsgProcAgent(config_file)
0025     agent.start()
0026     tmp_log.debug("started")
0027     # wait for stop event
0028     stop_event.wait()
0029     # stop
0030     tmp_log.debug("stopping")
0031     agent.stop()
0032     tmp_log.debug("stopped")