reconnect

ecotoneframework · Aug 27, 2024 · 732ba9d · 732ba9d
1 parent a156a3f
commit 732ba9d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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);
         }
     }