openstack/oslo.messaging
Code Issues Proposed changes

Add some logs when sending RPC messages

Browse Source 
Related-bug: #2031497

Signed-off-by: Arnaud Morin <arnaud.morin@ovhcloud.com>
Change-Id: I7d0c318624d3d02182392ca3f06eed04d4133728
This commit is contained in:
Arnaud Morin 2023-07-26 10:34:19 +02:00
parent f455edd601
commit 3438726dd0
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -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):