diff options
| author | Zuul <zuul@review.opendev.org> | 2020-01-15 13:15:32 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2020-01-15 13:15:32 +0000 |
| commit | 04b2b5d451df7d5aa4047a6b38aa364c400602a3 (patch) | |
| tree | 98fff7958f9978546a4dd54491d5eed01e727b31 | |
| parent | cc6cf12c3de704c470f15bc93564ef7ecdde5ad3 (diff) | |
| parent | e4a8900aa71aece02583f5f272b95766b12a851f (diff) | |
| download | oslo-messaging-04b2b5d451df7d5aa4047a6b38aa364c400602a3.tar.gz | |
Merge "Adding debug logs on AMQPListener poll"
| -rw-r--r-- | oslo_messaging/_drivers/amqpdriver.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py index b4d0a23..a41ff24 100644 --- a/oslo_messaging/_drivers/amqpdriver.py +++ b/oslo_messaging/_drivers/amqpdriver.py @@ -305,8 +305,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) @@ -316,8 +319,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: @@ -325,8 +330,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() |