From 8ab852f334c46297870486af18c9cac0272f09fa Mon Sep 17 00:00:00 2001 From: Tobias Urdin Date: Wed, 21 Aug 2024 08:25:39 +0200 Subject: [PATCH] Reduce log level to DEBUG for new messages 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 (cherry picked from commit d601f7aae0b775a7203441c83f3cd1d53b68990c) --- oslo_messaging/_drivers/amqpdriver.py | 8 ++++---- oslo_messaging/_drivers/impl_rabbit.py | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py index 1db25e7fa..474fe9a4d 100644 --- a/oslo_messaging/_drivers/amqpdriver.py +++ b/oslo_messaging/_drivers/amqpdriver.py @@ -504,7 +504,7 @@ class ReplyWaiters(object): 'to message ID %s' % msg_id) 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) if not queue: LOG.info('No calling threads waiting for msg_id : %s', msg_id) @@ -695,7 +695,7 @@ class AMQPDriverBase(base.BaseDriver): reply_q = 'reply_' + self._q_manager.get() else: 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) @@ -725,8 +725,8 @@ class AMQPDriverBase(base.BaseDriver): msg.update({'_msg_id': msg_id}) msg.update({'_reply_q': reply_q}) msg.update({'_timeout': call_monitor_timeout}) - LOG.info('Expecting reply to msg %s in queue %s', msg_id, - reply_q) + LOG.debug('Expecting reply to msg %s in queue %s', msg_id, + reply_q) rpc_amqp._add_unique_id(msg) unique_id = msg[rpc_amqp.UNIQUE_ID] diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 908fde916..b58d5f402 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1478,7 +1478,7 @@ class Connection(object): else: unique = uuid.uuid4().hex 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 self.rabbit_stream_fanout)