diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py index a860d69..879e779 100644 --- a/pyinfra/queue/queue_manager.py +++ b/pyinfra/queue/queue_manager.py @@ -76,8 +76,6 @@ class QueueManager(object): self._connection.close() self._consumer_token = None - else: - self.logger.info("No consumer-tag found, a possible subscription cannot be cancelled") def _create_queue_callback(self, process_message_callback: Callable): def callback(_channel, frame, properties, body):