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

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