openstack/oslo.messaging
Code Issues Proposed changes

Adding debug logs on AMQPListener poll

Browse Source 
Adding some debug logs to track execution on the AMQPListener poll
function to observe if workers incoming messages are dispatched to
workers and if listener is stuck.

Change-Id: Ia9b9ef62b0b59c78283c6a8cc5b7ce42282e73b5
This commit is contained in:
Hervé Beraud 2019-12-16 15:04:37 +01:00 committed by Stephen Finucane
parent 859e0d4eaa
commit e4a8900aa7
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

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