From eecb65894d00329b3085d2671fda65d36352df79 Mon Sep 17 00:00:00 2001 From: marcsello Date: Wed, 18 Aug 2021 15:56:24 +0200 Subject: [PATCH] Fixed routing keys --- src/magic_amqp.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/magic_amqp.py b/src/magic_amqp.py index de91dd6..652d92d 100644 --- a/src/magic_amqp.py +++ b/src/magic_amqp.py @@ -75,7 +75,7 @@ class MagicAMQP: if total_time > 1: self.app.logger.warning(f"Loop: Total loop took {total_time:5f} sec") - def _publish(self, exchange: str, payload=None): + def _publish(self, exchange: str, routing_key: str, payload=None): """ Publish a simple json serialized message to the configured queue. If the connection is broken, then this call will block until the connection is restored @@ -94,7 +94,7 @@ class MagicAMQP: try: self._pika_channel.basic_publish( exchange=exchange, - routing_key='feature', + routing_key=routing_key, body=json.dumps(payload).encode('UTF-8') ) self.app.logger.debug(f"Published: {payload}") @@ -125,10 +125,10 @@ class MagicAMQP: self.app.logger.warning(f"Publish: Total publish took {total_time:5f} sec") def publish_cache(self, payload=None): - return self._publish(self.app.config['EXCHANGE_NAME_CACHE'], payload) + return self._publish(self.app.config['EXCHANGE_NAME_CACHE'], "cache", payload) def publish_meta(self, payload=None): - return self._publish(self.app.config['EXCHANGE_NAME_META'], payload) + return self._publish(self.app.config['EXCHANGE_NAME_META'], "meta", payload) def is_healthy(self) -> bool: with self._lock: