@@ -64,7 +64,7 @@ discard block |
||
64 | 64 | $durable = ($type === self::QUEUE_DURABLE); |
65 | 65 | $exclusive = ($type === self::QUEUE_EXCLUSIVE); |
66 | 66 | |
67 | - list($name, ,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false); |
|
67 | + list($name,,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false); |
|
68 | 68 | |
69 | 69 | return $name; |
70 | 70 | } |
@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | */ |
80 | 80 | public function declareExchange($exchangeName = '', $type = self::EXCHANGE_TYPE_FANOUT) |
81 | 81 | { |
82 | - list($name, ,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false); |
|
82 | + list($name,,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false); |
|
83 | 83 | |
84 | 84 | return $name; |
85 | 85 | } |
@@ -181,7 +181,7 @@ discard block |
||
181 | 181 | $autoAck, |
182 | 182 | false, |
183 | 183 | false, |
184 | - function (AMQPMessage $message) use ($callback, $queueName) { |
|
184 | + function(AMQPMessage $message) use ($callback, $queueName) { |
|
185 | 185 | $burrowMessage = new Message( |
186 | 186 | $message->getBody(), |
187 | 187 | '', // Impossible to retrieve here |