needle-project / laravel-rabbitmq

src/Entity/QueueEntity.php

Spacing +8 added lines, -8 removed lines

@@ -235,8 +235,8 @@ 
                 $this->logger->critical(sprintf(
                     "Stopped consuming: %s in %s:%d",
                     $e->getMessage(),
-                    (string)$e->getFile(),
-                    (int)$e->getLine()
+                    (string) $e->getFile(),
+                    (int) $e->getLine()
                 ));
                 return 1;
             }
@@ -264,7 +264,7 @@ 
                 "Stopped consumer",
                 [
                     'limit' => 'memory_limit',
-                    'value' => (int)round(memory_get_peak_usage(true) / 1048576, 2)
+                    'value' => (int) round(memory_get_peak_usage(true) / 1048576, 2)
                 ]
             );
             return true;
@@ -273,7 +273,7 @@ 
         if ($this->getMessageProcessor()->getProcessedMessages() >= $this->limitMessageCount) {
             $this->logger->debug(
                 "Stopped consumer",
-                ['limit' => 'message_count', 'value' => (int)$this->getMessageProcessor()->getProcessedMessages()]
+                ['limit' => 'message_count', 'value' => (int) $this->getMessageProcessor()->getProcessedMessages()]
             );
             return true;
         }
@@ -289,7 +289,7 @@ 
         try {
             $this->getChannel()->basic_cancel($this->getConsumerTag(), false, true);
         } catch (\Throwable $e) {
-            $this->logger->notice("Got " . $e->getMessage() . " of type " . get_class($e));
+            $this->logger->notice("Got ".$e->getMessage()." of type ".get_class($e));
         }
     }
 
@@ -340,7 +340,7 @@ 
     private function registerShutdownHandler()
     {
         $consumer = $this;
-        register_shutdown_function(function () use ($consumer) {
+        register_shutdown_function(function() use ($consumer) {
             $consumer->stopConsuming();
         });
     }
@@ -410,8 +410,8 @@ 
                 sprintf(
                     "Got %s from %s in %d",
                     $e->getMessage(),
-                    (string)$e->getFile(),
-                    (int)$e->getLine()
+                    (string) $e->getFile(),
+                    (int) $e->getLine()
                 )
             );
             // let the exception slide, the processor should handle

src/AMQPConnection.php

Spacing +3 added lines, -3 removed lines

@@ -28,7 +28,7 @@ 
         'lazy'               => true,
 
         # More info about timeouts can be found on https://www.rabbitmq.com/networking.html
-        'read_write_timeout' => 16,   // default timeout for writing/reading (in seconds)
+        'read_write_timeout' => 16, // default timeout for writing/reading (in seconds)
         'connect_timeout'    => 10,
         'heartbeat'          => 8
     ];
@@ -64,7 +64,7 @@ 
             throw new \InvalidArgumentException(
                 sprintf(
                     "Cannot create connection %s, received unknown arguments: %s!",
-                    (string)$aliasName,
+                    (string) $aliasName,
                     implode(', ', $diff)
                 )
             );
@@ -86,7 +86,7 @@ 
     {
         $this->aliasName = $aliasName;
         $this->connectionDetails = $connectionDetails;
-        if (isset($connectionDetails['lazy']) &&  $connectionDetails['lazy'] === false) {
+        if (isset($connectionDetails['lazy']) && $connectionDetails['lazy'] === false) {
             // dummy call
             $this->getConnection();
         }