diff --git a/pyinfra/queue/manager.py b/pyinfra/queue/manager.py
index ea9c1b4..da49299 100644
--- a/pyinfra/queue/manager.py
+++ b/pyinfra/queue/manager.py
@@ -80,6 +80,7 @@ class QueueManager:
         self.establish_connection()
         return self.channel.is_open
 
+    @retry(exceptions=pika.exceptions.AMQPConnectionError, tries=3, delay=5, jitter=(1, 3), logger=logger)
     def start_consuming(self, message_processor: Callable):
         on_message_callback = self._make_on_message_callback(message_processor)