Merge pull request #5 from chocopowwwa/patch-1

makasim · web-flow · commit 6742995e900b · 2018-03-05T11:19:09.000+02:00
Update AmqpQueue.php
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);`