openstack/oslo.messaging
Code Issues Proposed changes

Merge "Adding debug logs on AMQPListener poll"

Browse Source
This commit is contained in:
Zuul 2020-01-15 13:15:32 +00:00 committed by Gerrit Code Review
commit 04b2b5d451
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oslo_messaging/_drivers/amqpdriver.py
View File

@ -305,8 +305,11 @@ class AMQPListener(base.PollStyleListener):
while not self._shutdown.is_set(): while not self._shutdown.is_set():
self._message_operations_handler.process() self._message_operations_handler.process()
LOG.debug("Listener is running")
if self.incoming: if self.incoming:
LOG.debug("Poll the incoming message with unique_id: %s",
self.incoming[0].unique_id)
return self.incoming.pop(0) return self.incoming.pop(0)
left = stopwatch.leftover(return_none=True) left = stopwatch.leftover(return_none=True)
@ -316,8 +319,10 @@ class AMQPListener(base.PollStyleListener):
return None return None
try: try:
LOG.debug("AMQPListener connection consume")
self.conn.consume(timeout=min(self._current_timeout, left)) self.conn.consume(timeout=min(self._current_timeout, left))
except rpc_common.Timeout: except rpc_common.Timeout:
LOG.debug("AMQPListener connection timeout")
self._current_timeout = max(self._current_timeout * 2, self._current_timeout = max(self._current_timeout * 2,
ACK_REQUEUE_EVERY_SECONDS_MAX) ACK_REQUEUE_EVERY_SECONDS_MAX)
else: else:
@ -325,8 +330,11 @@ class AMQPListener(base.PollStyleListener):
# NOTE(sileht): listener is stopped, just processes remaining messages # NOTE(sileht): listener is stopped, just processes remaining messages
# and operations # and operations
LOG.debug("Listener is stopped")
self._message_operations_handler.process() self._message_operations_handler.process()
if self.incoming: if self.incoming:
LOG.debug("Poll the incoming message with unique_id: %s",
self.incoming[0].unique_id)
return self.incoming.pop(0) return self.incoming.pop(0)
self._shutoff.set() self._shutoff.set()