amqp reconnect on sending failure

Author: dgafka

packages/Amqp/src/AmqpOutboundChannelAdapter.php

@@ -11,6 +11,8 @@
 use Ecotone\Messaging\MessageHandler;
 use Interop\Amqp\AmqpMessage;
 use Interop\Amqp\Impl\AmqpTopic;
+use AMQPChannelException;
+use AMQPConnectionException;
 
 /**
  * @author  Dariusz Gafka <support@simplycodedsoftware.com>
@@ -74,11 +76,17 @@ public function handle(Message $message): void
         $messageToSend
             ->setDeliveryMode($this->defaultPersistentDelivery ? AmqpMessage::DELIVERY_MODE_PERSISTENT : AmqpMessage::DELIVERY_MODE_NON_PERSISTENT);
 
-        $this->connectionFactory->getProducer()
-            ->setTimeToLive($outboundMessage->getTimeToLive())
-            ->setDelayStrategy(new HeadersExchangeDelayStrategy())
-            ->setDeliveryDelay($outboundMessage->getDeliveryDelay())
+        try {
+            $this->connectionFactory->getProducer()
+                ->setTimeToLive($outboundMessage->getTimeToLive())
+                ->setDelayStrategy(new HeadersExchangeDelayStrategy())
+                ->setDeliveryDelay($outboundMessage->getDeliveryDelay())
 //            this allow for having queue per delay instead of queue per delay + exchangeName
-            ->send(new AmqpTopic($exchangeName), $messageToSend);
+                ->send(new AmqpTopic($exchangeName), $messageToSend);
+        }catch (AMQPConnectionException|AMQPChannelException $exception) {
+            $this->connectionFactory->reconnect();
+
+            throw $exception;
+        }
     }
 }