diff --git a/pyinfra/queue/queue_manager/pika_queue_manager.py b/pyinfra/queue/queue_manager/pika_queue_manager.py
index ad5191a..ad1ecfa 100644
--- a/pyinfra/queue/queue_manager/pika_queue_manager.py
+++ b/pyinfra/queue/queue_manager/pika_queue_manager.py
@@ -147,10 +147,15 @@ class PikaQueueManager(QueueManager):
 
         try:
             consumer_tag = self.channel.basic_consume(self._input_queue, callback)
+            logger.info(f"Connected to message-queue with consumer-tag|{consumer_tag}")
+
             self.channel.start_consuming()
         finally:
             if consumer_tag:
+                logger.info(f"Cancelling subscription for consumer-tag|{consumer_tag}")
                 self.channel.basic_cancel(consumer_tag)
+            else:
+                logger.info(f"Aborting listening on queue before a consumer-tag was received")
 
     def clear(self):
         try: