From 11cd78d97f510fcbf3c476c67db5907bceca4fb1 Mon Sep 17 00:00:00 2001 From: ChocoPowwwa Date: Mon, 5 Mar 2018 10:13:59 +0700 Subject: [PATCH] Update AmqpQueue.php https://github.com/php-enqueue/laravel-queue/blob/master/src/Queue.php#L107 the get queue method already return `Interop\Queue\PsrQueue` --- src/AmqpQueue.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);