diff --git a/src/AmqpQueue.php b/src/AmqpQueue.php index d409849..49087be 100644 --- a/src/AmqpQueue.php +++ b/src/AmqpQueue.php @@ -57,6 +57,6 @@ protected function declareQueue($queue = null) $interopQueue = $this->getQueue($queue); $interopQueue->addFlag(\Interop\Amqp\AmqpQueue::FLAG_DURABLE); - $this->getQueueInteropContext()->declareQueue($queue); + $this->getQueueInteropContext()->declareQueue($interopQueue); } }