From e274dfd52ef6db1b60a765a6c627e0a5af5945c9 Mon Sep 17 00:00:00 2001 From: Dmitry Ozerov Date: Mon, 14 Feb 2022 16:56:21 +0100 Subject: [PATCH] rabbitmq tag for new epics_writer --- sf_daq_broker/rabbitmq/msg_broker_client.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sf_daq_broker/rabbitmq/msg_broker_client.py b/sf_daq_broker/rabbitmq/msg_broker_client.py index 755794d..b587216 100644 --- a/sf_daq_broker/rabbitmq/msg_broker_client.py +++ b/sf_daq_broker/rabbitmq/msg_broker_client.py @@ -52,6 +52,8 @@ class RabbitMqClient(object): routing_key = broker_config.DETECTOR_CONVERSION_ROUTE elif ( tag == broker_config.TAG_PEDESTAL or tag == broker_config.TAG_POWER_ON ): routing_key = broker_config.DETECTOR_PEDESTAL_ROUTE + elif ( tag.startswith('epics_') ): + routing_key = tag request_id = str(uuid.uuid4()) body_bytes = json.dumps(write_request).encode()