mucts / laravel-amqp

src/AMQPManager.php

Spacing +2 added lines, -2 removed lines

@@ -295,7 +295,7 @@ 
             false, $this->getAutoAck(),
             false,
             false,
-            function ($message) use ($processMessage) {
+            function($message) use ($processMessage) {
                 /** @var AMQPMessage $message */
                 $message = new Message($message);
                 return $processMessage($message);
@@ -320,7 +320,7 @@ 
          * @param AMQPChannel $channel
          * @param AbstractConnection $connection
          */
-        return function ($channel, $connection) {
+        return function($channel, $connection) {
             $channel->close();
             $connection->close();
         };

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]);
         }
 

src/Providers/ServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         $this->mergeConfigFrom(
             dirname(__DIR__) . '/../config/amqp.php', 'amqp'
         );
-        $this->app->singleton(AMQPManager::class, function ($app) {
+        $this->app->singleton(AMQPManager::class, function($app) {
             return new AMQPManager($app);
         });
         $this->app->alias(AMQPManager::class, 'amqp');

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

@@ -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());
         }
     }