From 3438726dd08eef03a0962c72096f268a54fd7f4e Mon Sep 17 00:00:00 2001 From: Arnaud Morin Date: Wed, 26 Jul 2023 10:34:19 +0200 Subject: [PATCH] Add some logs when sending RPC messages Related-bug: #2031497 Signed-off-by: Arnaud Morin Change-Id: I7d0c318624d3d02182392ca3f06eed04d4133728 --- oslo_messaging/_drivers/impl_rabbit.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index e88c58c88..205758f2b 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1515,6 +1515,8 @@ class Connection(object): passive=True) options = oslo_messaging.TransportOptions( at_least_once=self.direct_mandatory_flag) + + LOG.debug('Sending direct to %s', msg_id) self._ensure_publishing(self._publish_and_raises_on_missing_exchange, exchange, msg, routing_key=msg_id, transport_options=options) @@ -1528,6 +1530,8 @@ class Connection(object): durable=self.durable, auto_delete=self.amqp_auto_delete) + LOG.debug('Sending topic to %s with routing_key %s', exchange_name, + topic) self._ensure_publishing(self._publish, exchange, msg, routing_key=topic, timeout=timeout, retry=retry, @@ -1540,6 +1544,7 @@ class Connection(object): durable=False, auto_delete=True) + LOG.debug('Sending fanout to %s_fanout', topic) self._ensure_publishing(self._publish, exchange, msg, retry=retry) def notify_send(self, exchange_name, topic, msg, retry=None, **kwargs):