diff --git a/src/Monolog/Handler/AmqpHandler.php b/src/Monolog/Handler/AmqpHandler.php index bb2fbb7b..330416ba 100644 --- a/src/Monolog/Handler/AmqpHandler.php +++ b/src/Monolog/Handler/AmqpHandler.php @@ -40,7 +40,7 @@ class AmqpHandler extends AbstractProcessingHandler { if ($exchange instanceof AMQPChannel) { $this->exchangeName = $exchangeName; - } elseif (!$exchange instanceof AMQPChannel) { + } elseif (!$exchange instanceof AMQPExchange) { throw new \InvalidArgumentException('PhpAmqpLib\Channel\AMQPChannel or AMQPExchange instance required'); } $this->exchange = $exchange;