@@ -90,7 +90,7 @@ discard block |
||
| 90 | 90 | $this->channel = $this->connection->channel(); |
| 91 | 91 | } |
| 92 | 92 | |
| 93 | - list($this->queue_name, , ) = $this->channel->queue_declare( |
|
| 93 | + list($this->queue_name,,) = $this->channel->queue_declare( |
|
| 94 | 94 | "", |
| 95 | 95 | $passive, |
| 96 | 96 | false, |
@@ -133,11 +133,11 @@ discard block |
||
| 133 | 133 | throw new \ErrorException('An exchange has not been defined.'); |
| 134 | 134 | } |
| 135 | 135 | |
| 136 | - $this->channel->set_ack_handler(function (AMQPMessage $message) { |
|
| 136 | + $this->channel->set_ack_handler(function(AMQPMessage $message) { |
|
| 137 | 137 | Log::info('AMQP Message ACK'); |
| 138 | 138 | }); |
| 139 | 139 | |
| 140 | - $this->channel->set_nack_handler(function (AMQPMessage $message) { |
|
| 140 | + $this->channel->set_nack_handler(function(AMQPMessage $message) { |
|
| 141 | 141 | Log::error('AMQP Message NACK'); |
| 142 | 142 | }); |
| 143 | 143 | |
@@ -161,7 +161,7 @@ discard block |
||
| 161 | 161 | throw new \ErrorException('A queue, or exchange, have not been defined.'); |
| 162 | 162 | } |
| 163 | 163 | |
| 164 | - $callback = function ($msg) { |
|
| 164 | + $callback = function($msg) { |
|
| 165 | 165 | return $this->response = $msg->body; |
| 166 | 166 | }; |
| 167 | 167 | |