Update AmqpQueue.php

chocopowwwa · web-flow · commit 11cd78d97f51 · 2018-03-05T10:13:59.000+07:00
https://github.com/php-enqueue/laravel-queue/blob/master/src/Queue.php#L107 the get queue method already return `Interop\Queue\PsrQueue`
diff --git 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);

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public function pop($queue = null)`
`54`	`54`	`*/`
`55`	`55`	`protected function declareQueue($queue = null)`
`56`	`56`	`{`
`57`		`- $psrQueue = $this->getPsrContext()->createQueue($this->getQueue($queue));`
	`57`	`+ $psrQueue = $this->getQueue($queue);`
`58`	`58`	`$psrQueue->addFlag(\Interop\Amqp\AmqpQueue::FLAG_DURABLE);`
`59`	`59`
`60`	`60`	`$this->getPsrContext()->declareQueue($psrQueue);`