@@ -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 |