diff --git a/src/AmqpQueue.php b/src/AmqpQueue.php index e06bfd1..1f06825 100644 --- a/src/AmqpQueue.php +++ b/src/AmqpQueue.php @@ -54,7 +54,7 @@ public function pop($queue = null) */ protected function declareQueue($queue = null) { - $psrQueue = $this->getPsrContext()->createQueue($this->getQueue($queue)); + $psrQueue = $this->getQueue($queue); $psrQueue->addFlag(\Interop\Amqp\AmqpQueue::FLAG_DURABLE); $this->getPsrContext()->declareQueue($psrQueue);