Merge pull request #10 from matchbookmac/patch-1

makasim · web-flow · commit 617902648bf1 · 2019-01-24T10:34:24.000+02:00
declareQueue using wrong queue object
diff --git 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);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,6 @@ protected function declareQueue($queue = null)`
`57`	`57`	`$interopQueue = $this->getQueue($queue);`
`58`	`58`	`$interopQueue->addFlag(\Interop\Amqp\AmqpQueue::FLAG_DURABLE);`
`59`	`59`
`60`		`- $this->getQueueInteropContext()->declareQueue($queue);`
	`60`	`+ $this->getQueueInteropContext()->declareQueue($interopQueue);`
`61`	`61`	`}`
`62`	`62`	`}`