mucts / laravel-amqp

src/Commands/AMQPCommand.php

Spacing +2 added lines, -2 removed lines

@@ -79,11 +79,11 @@
                 ->setConsumerTag($this->consumerTag)
                 ->setAutoAck($this->autoAsk)
                 ->setRouteKey($this->routeKey)
-                ->consume(function ($message) {
+                ->consume(function($message) {
                     /** @var Message $message */
                     return static::processMessage($message);
                 });
-        } catch (InvalidArgumentException|ErrorException|Exception $exception) {
+        } catch (InvalidArgumentException | ErrorException | Exception $exception) {
             Log::error('AMQPMessage consume error:' . $exception->getMessage());
         }
     }

src/AMQPManager.php

Braces +11 added lines, -4 removed lines

@@ -153,7 +153,9 @@ 
     protected function makeConnection(string $name)
     {
         $config = $this->configuration($name);
-        if (isset($config['host'])) $config = [$config];
+        if (isset($config['host'])) {
+            $config = [$config];
+        }
         return AMQPStreamConnection::create_connection($config);
     }
 
@@ -429,10 +431,15 @@ 
 
         $channel->queue_bind($this->getQueue(), $this->getExchange());
 
-        if ($message instanceof Message) $message->getMessage();
+        if ($message instanceof Message) {
+            $message->getMessage();
+        }
         if (!$message instanceof AMQPMessage) {
-            if ($message instanceof Collection) $message = $message->toJson();
-            elseif (is_array($message) || is_object($message)) $message = json_encode($message);
+            if ($message instanceof Collection) {
+                $message = $message->toJson();
+            } elseif (is_array($message) || is_object($message)) {
+                $message = json_encode($message);
+            }
             $message = new AMQPMessage($message, ['content_type' => 'text/plain', 'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);
         }