mucts / laravel-amqp

src/AMQPManager.php

Braces +8 added lines, -3 removed lines

@@ -108,7 +108,9 @@ 
     public 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);
     }
 
@@ -362,8 +364,11 @@ 
         $channel->queue_bind($this->getQueue(), $this->getExchange());
 
         if (!$message instanceof AMQPMessage) {
-            if (is_array($message) || is_object($message)) $message = json_encode($message);
-            elseif ($message instanceof Collection) $message = $message->toJson();
+            if (is_array($message) || is_object($message)) {
+                $message = json_encode($message);
+            } elseif ($message instanceof Collection) {
+                $message = $message->toJson();
+            }
             $message = new AMQPMessage($message, ['content_type' => 'text/plain', 'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);
         }