@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | ]; |
| 84 | 84 | } |
| 85 | 85 | |
| 86 | - return []; |
|
| 86 | + return [ ]; |
|
| 87 | 87 | } |
| 88 | 88 | |
| 89 | 89 | /** |
@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | $this->channel = $this->connection->channel(); |
| 125 | 125 | } |
| 126 | 126 | |
| 127 | - list($this->queue_name, ,) = $this->channel->queue_declare( |
|
| 127 | + list($this->queue_name,,) = $this->channel->queue_declare( |
|
| 128 | 128 | "", |
| 129 | 129 | $passive, |
| 130 | 130 | false, |
@@ -167,11 +167,11 @@ discard block |
||
| 167 | 167 | throw new \ErrorException('An exchange has not been defined.'); |
| 168 | 168 | } |
| 169 | 169 | |
| 170 | - $this->channel->set_ack_handler(function (AMQPMessage $message) { |
|
| 170 | + $this->channel->set_ack_handler(function(AMQPMessage $message) { |
|
| 171 | 171 | Log::info('AMQP Message ACK'); |
| 172 | 172 | }); |
| 173 | 173 | |
| 174 | - $this->channel->set_nack_handler(function (AMQPMessage $message) { |
|
| 174 | + $this->channel->set_nack_handler(function(AMQPMessage $message) { |
|
| 175 | 175 | Log::error('AMQP Message NACK'); |
| 176 | 176 | }); |
| 177 | 177 | |
@@ -195,7 +195,7 @@ discard block |
||
| 195 | 195 | throw new \ErrorException('A queue, or exchange, have not been defined.'); |
| 196 | 196 | } |
| 197 | 197 | |
| 198 | - $callback = function ($msg) { |
|
| 198 | + $callback = function($msg) { |
|
| 199 | 199 | return $this->response = $msg->body; |
| 200 | 200 | }; |
| 201 | 201 | |