mucts / laravel-amqp

src/AMQPManager.php

Braces +11 added lines, -4 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);
     }
 
@@ -361,10 +363,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 (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]);
         }
 

src/Message.php

Spacing +1 added lines, -1 removed lines

@@ -51,7 +51,7 @@
      *
      * @return AMQPMessage
      */
-    public function getMessage(){
+    public function getMessage() {
         return $this->message;
     }
 

src/Commands/AMQPCommand.php

Spacing +2 added lines, -2 removed lines

@@ -40,11 +40,11 @@
                 ->setQueue($this->queue)
                 ->setConsumerTag($this->consumerTag)
                 ->setAutoAck($this->autoAsk)
-                ->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());
         }
     }