From 732ba9dcd8e9393f61f6a7723a8ea72885d5d465 Mon Sep 17 00:00:00 2001
From: Dariusz Gafka <dariuszgafka@gmail.com>
Date: Tue, 27 Aug 2024 20:40:18 +0200
Subject: [PATCH] reconnect

---
 packages/Amqp/src/AmqpInboundChannelAdapter.php | 1 +
 1 file changed, 1 insertion(+)

diff --git a/packages/Amqp/src/AmqpInboundChannelAdapter.php b/packages/Amqp/src/AmqpInboundChannelAdapter.php
index 9b46b0d8e..44ffa233a 100644
--- a/packages/Amqp/src/AmqpInboundChannelAdapter.php
+++ b/packages/Amqp/src/AmqpInboundChannelAdapter.php
@@ -104,6 +104,7 @@ public function receiveWithTimeout(int $timeout = 0): ?Message
 
             return $this->queueChannel->receive();
         } catch (AMQPConnectionException|\AMQPChannelException $exception) {
+            $this->connectionFactory->reconnect();
             throw new ConnectionException('Failed to connect to AMQP broker', 0, $exception);
         }
     }