openstack/oslo.messaging
Code Issues Proposed changes

Reduce log level to DEBUG for new messages

Browse Source 
The change [1] introduced new logging that
uses INFO loglevel instead of DEBUG with
messages that doesn't help and instead
when there is a lot of messages fills
up the log file.

[1] https://review.opendev.org/c/openstack/oslo.messaging/+/889425

Change-Id: Ide5eb73164632c4e7be8582ba7bc2acde8287c78
This commit is contained in:
Tobias Urdin 2024-08-21 08:25:39 +02:00
parent 133ca65fa4
commit d601f7aae0
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oslo_messaging/_drivers/amqpdriver.py
View File

@ -510,7 +510,7 @@ class ReplyWaiters(object):
'to message ID %s' % msg_id) 'to message ID %s' % msg_id)
def put(self, msg_id, message_data): def put(self, msg_id, message_data):
LOG.info('Received RPC response for msg %s', msg_id) LOG.debug('Received RPC response for msg %s', msg_id)
queue = self._queues.get(msg_id) queue = self._queues.get(msg_id)
if not queue: if not queue:
LOG.info('No calling threads waiting for msg_id : %s', msg_id) LOG.info('No calling threads waiting for msg_id : %s', msg_id)
@ -701,7 +701,7 @@ class AMQPDriverBase(base.BaseDriver):
reply_q = 'reply_' + self._q_manager.get() reply_q = 'reply_' + self._q_manager.get()
else: else:
reply_q = 'reply_' + uuid.uuid4().hex reply_q = 'reply_' + uuid.uuid4().hex
LOG.info('Creating reply queue: %s', reply_q) LOG.debug('Creating reply queue: %s', reply_q)
conn = self._get_connection(rpc_common.PURPOSE_LISTEN) conn = self._get_connection(rpc_common.PURPOSE_LISTEN)
@ -731,8 +731,8 @@ class AMQPDriverBase(base.BaseDriver):
msg.update({'_msg_id': msg_id}) msg.update({'_msg_id': msg_id})
msg.update({'_reply_q': reply_q}) msg.update({'_reply_q': reply_q})
msg.update({'_timeout': call_monitor_timeout}) msg.update({'_timeout': call_monitor_timeout})
LOG.info('Expecting reply to msg %s in queue %s', msg_id, LOG.debug('Expecting reply to msg %s in queue %s', msg_id,
reply_q) reply_q)
rpc_amqp._add_unique_id(msg) rpc_amqp._add_unique_id(msg)
unique_id = msg[rpc_amqp.UNIQUE_ID] unique_id = msg[rpc_amqp.UNIQUE_ID]

2
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -1525,7 +1525,7 @@ class Connection(object):
else: else:
unique = uuid.uuid4().hex unique = uuid.uuid4().hex
queue_name = '%s_fanout_%s' % (topic, unique) queue_name = '%s_fanout_%s' % (topic, unique)
LOG.info('Creating fanout queue: %s', queue_name) LOG.debug('Creating fanout queue: %s', queue_name)
is_durable = (self.rabbit_transient_quorum_queue or is_durable = (self.rabbit_transient_quorum_queue or
self.rabbit_stream_fanout) self.rabbit_stream_fanout)