initialize

ecotoneframework · Aug 27, 2024 · a156a3f · a156a3f
1 parent c6a93b2
commit a156a3f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packages/Amqp/src/AmqpInboundChannelAdapter.php b/packages/Amqp/src/AmqpInboundChannelAdapter.php
@@ -103,7 +103,7 @@ public function receiveWithTimeout(int $timeout = 0): ?Message
             $subscriptionConsumer->consume($timeout ?: $this->receiveTimeoutInMilliseconds);
 
             return $this->queueChannel->receive();
-        } catch (AMQPConnectionException $exception) {
+        } catch (AMQPConnectionException|\AMQPChannelException $exception) {
             throw new ConnectionException('Failed to connect to AMQP broker', 0, $exception);
         }
     }

diff --git a/packages/Enqueue/src/EnqueueInboundChannelAdapter.php b/packages/Enqueue/src/EnqueueInboundChannelAdapter.php
@@ -83,7 +83,7 @@ abstract public function connectionException(): string;
 
     private function isConnectionException(Exception $exception): bool
     {
-        return is_subclass_of($exception, $this->connectionException()) || $exception::class === $this->connectionException() || $exception instanceof ConnectionException;
+        return is_subclass_of($exception, $this->connectionException()) || $exception::class === $this->connectionException();
     }
 
     public function getQueueName(): string