mucts / laravel-amqp

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);
     }
 
@@ -418,10 +420,15 @@ 
         /** @var AMQPChannel $channel */
         list($connection, $channel) = $this->startConnection();
 
-        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]);
         }