pandajedi/jedimsgprocessor/forwarding_msg_processor.py

0001 from pandacommon.pandalogger import logger_utils
0002
0003 from pandajedi.jedimsgprocessor.base_msg_processor import BaseMsgProcPlugin
0004
0005 base_logger = logger_utils.setup_logger(__name__.split(".")[-1])
0006
0007
0008 # forwarding message processing plugin
0009 class ForwardingMsgProcPlugin(BaseMsgProcPlugin):
0010     """
0011     Simply forward the message from one queue to another
0012     """
0013
0014     def process(self, msg_obj):
0015         tmp_log = logger_utils.make_logger(base_logger, token=self.get_pid(), method_name="process")
0016         # start
0017         # tmp_log.info('start')
0018         # tmp_log.debug('sub_id={0} ; msg_id={1}'.format(msg_obj.sub_id, msg_obj.msg_id))
0019         # run
0020         try:
0021             msg = msg_obj.data
0022             tmp_log.debug(f"forward message {msg}")
0023         except Exception as e:
0024             err_str = f"failed to run, skipped. {e.__class__.__name__} : {e}"
0025             tmp_log.error(err_str)
0026             raise
0027         # done
0028         # tmp_log.info('done')
0029         return msg