@@ -295,7 +295,7 @@ discard block |
||
295 | 295 | false, $this->getAutoAck(), |
296 | 296 | false, |
297 | 297 | false, |
298 | - function ($message) use ($processMessage) { |
|
298 | + function($message) use ($processMessage) { |
|
299 | 299 | /** @var AMQPMessage $message */ |
300 | 300 | $message = new Message($message); |
301 | 301 | return $processMessage($message); |
@@ -320,7 +320,7 @@ discard block |
||
320 | 320 | * @param AMQPChannel $channel |
321 | 321 | * @param AbstractConnection $connection |
322 | 322 | */ |
323 | - return function ($channel, $connection) { |
|
323 | + return function($channel, $connection) { |
|
324 | 324 | $channel->close(); |
325 | 325 | $connection->close(); |
326 | 326 | }; |
@@ -108,7 +108,9 @@ discard block |
||
108 | 108 | public function makeConnection(string $name) |
109 | 109 | { |
110 | 110 | $config = $this->configuration($name); |
111 | - if (isset($config['host'])) $config = [$config]; |
|
111 | + if (isset($config['host'])) { |
|
112 | + $config = [$config]; |
|
113 | + } |
|
112 | 114 | return AMQPStreamConnection::create_connection($config); |
113 | 115 | } |
114 | 116 | |
@@ -362,8 +364,11 @@ discard block |
||
362 | 364 | $channel->queue_bind($this->getQueue(), $this->getExchange()); |
363 | 365 | |
364 | 366 | if (!$message instanceof AMQPMessage) { |
365 | - if (is_array($message) || is_object($message)) $message = json_encode($message); |
|
366 | - elseif ($message instanceof Collection) $message = $message->toJson(); |
|
367 | + if (is_array($message) || is_object($message)) { |
|
368 | + $message = json_encode($message); |
|
369 | + } elseif ($message instanceof Collection) { |
|
370 | + $message = $message->toJson(); |
|
371 | + } |
|
367 | 372 | $message = new AMQPMessage($message, ['content_type' => 'text/plain', 'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]); |
368 | 373 | } |
369 | 374 |
@@ -23,7 +23,7 @@ |
||
23 | 23 | $this->mergeConfigFrom( |
24 | 24 | dirname(__DIR__) . '/../config/amqp.php', 'amqp' |
25 | 25 | ); |
26 | - $this->app->singleton(AMQPManager::class, function ($app) { |
|
26 | + $this->app->singleton(AMQPManager::class, function($app) { |
|
27 | 27 | return new AMQPManager($app); |
28 | 28 | }); |
29 | 29 | $this->app->alias(AMQPManager::class, 'amqp'); |
@@ -37,7 +37,7 @@ |
||
37 | 37 | ->setQueue($this->queue) |
38 | 38 | ->setConsumerTag($this->consumerTag) |
39 | 39 | ->setAutoAck($this->autoAsk) |
40 | - ->consume(function ($message) { |
|
40 | + ->consume(function($message) { |
|
41 | 41 | /** @var Message $message */ |
42 | 42 | return static::processMessage($message); |
43 | 43 | }); |