needle-project / laravel-rabbitmq

src/Command/SetupCommand.php

Spacing +22 added lines, -22 removed lines

@@ -26,7 +26,7 @@ 
      *
      * @var string
      */
-    protected $description = 'Create all queues, exchanges and binds that are defined in entities AND referenced to' .
+    protected $description = 'Create all queues, exchanges and binds that are defined in entities AND referenced to'.
         ' either a publisher or a consumer';
 
     /**
@@ -58,8 +58,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Created entity <info>%s</info> for publisher [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName
                     )
                 );
             } catch (\Exception $e) {
@@ -67,9 +67,9 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not create entity %s for publisher [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName,
+                        (string) $e->getMessage()
                     )
                 );
             }
@@ -83,8 +83,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Created entity <info>%s</info> for consumer [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName
                     )
                 );
             } catch (\Exception $e) {
@@ -92,9 +92,9 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not create entity %s for consumer [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName,
+                        (string) $e->getMessage()
                     )
                 );
             }
@@ -109,8 +109,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Created bind <info>%s</info> for publisher [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName
                     )
                 );
             } catch (\Exception $e) {
@@ -118,9 +118,9 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not bind entity %s for publisher [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName,
+                        (string) $e->getMessage()
                     )
                 );
             }
@@ -133,8 +133,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Bind entity <info>%s</info> for consumer [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName
                     )
                 );
             } catch (\Exception $e) {
@@ -142,13 +142,13 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not create bind %s for consumer [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName,
+                        (string) $e->getMessage()
                     )
                 );
             }
         }
-        return (int)$hasErrors;
+        return (int) $hasErrors;
     }
 }

src/Command/DeleteAllCommand.php

Spacing +12 added lines, -12 removed lines

@@ -26,7 +26,7 @@ 
      *
      * @var string
      */
-    protected $description = 'Delete all queues, exchanges and binds that are defined in entities AND referenced to' .
+    protected $description = 'Delete all queues, exchanges and binds that are defined in entities AND referenced to'.
     ' either a publisher or a consumer';
 
     /**
@@ -58,8 +58,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Deleted entity <info>%s</info> for publisher [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName
                     )
                 );
             } catch (\Exception $e) {
@@ -67,9 +67,9 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not delete entity %s for publisher [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName,
+                        (string) $e->getMessage()
                     )
                 );
             }
@@ -82,8 +82,8 @@ 
                 $this->output->writeln(
                     sprintf(
                         "Deleted entity <info>%s</info> for consumer [<fg=yellow>%s</>]",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName
                     )
                 );
             } catch (\Exception $e) {
@@ -91,13 +91,13 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not delete entity %s for consumer [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$consumerAliasName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $consumerAliasName,
+                        (string) $e->getMessage()
                     )
                 );
             }
         }
-        return (int)$hasErrors;
+        return (int) $hasErrors;
     }
 }

src/Processor/CliOutputProcessor.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      */
     public function processMessage(AMQPMessage $message): bool
     {
-        echo $message->getBody() . "\n";
+        echo $message->getBody()."\n";
         return true;
     }
 }

src/Builder/ContainerBuilder.php

Spacing +8 added lines, -8 removed lines

@@ -39,8 +39,8 @@ 
                 throw new \RuntimeException(
                     sprintf(
                         "Cannot create publisher %s: no exchange or queue named %s defined!",
-                        (string)$publisherAliasName,
-                        (string)$publisherEntityBind
+                        (string) $publisherAliasName,
+                        (string) $publisherEntityBind
                     )
                 );
             }
@@ -62,8 +62,8 @@ 
                 throw new \RuntimeException(
                     sprintf(
                         "Cannot create consumer %s: no queue named %s defined!",
-                        (string)$consumerAliasName,
-                        (string)$consumerDetails['queue']
+                        (string) $consumerAliasName,
+                        (string) $consumerDetails['queue']
                     )
                 );
             }
@@ -109,8 +109,8 @@ 
                 throw new \RuntimeException(
                     sprintf(
                         "Could not create exchange %s: connection name %s is not defined!",
-                        (string)$exchangeAliasName,
-                        (string)$exchangeDetails['connection']
+                        (string) $exchangeAliasName,
+                        (string) $exchangeDetails['connection']
                     )
                 );
             }
@@ -142,8 +142,8 @@ 
                 throw new \RuntimeException(
                     sprintf(
                         "Could not create exchange %s: connection name %s is not defined!",
-                        (string)$queueAliasName,
-                        (string)$queueDetails['connection']
+                        (string) $queueAliasName,
+                        (string) $queueDetails['connection']
                     )
                 );
             }

src/ConsumerInterface.php

Doc Comments +2 added lines, -1 removed lines

@@ -15,12 +15,13 @@
      * @param int $messages The number of message
      * @param int $seconds  The amount of time a consumer should listen for messages
      * @param int $maxMemory    The amount of memory when a consumer should stop consuming
-     * @return mixed
+     * @return integer
      */
     public function startConsuming(int $messages, int $seconds, int $maxMemory);
 
     /**
      * Stop the consumer
+     * @return void
      */
     public function stopConsuming();
 }

config/laravel_rabbitmq_example.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
             'lazy'               => true,
 
             # More info about timeouts can be found on https://www.rabbitmq.com/networking.html
-            'read_write_timeout' => 8,   // default timeout for writing/reading (in seconds)
+            'read_write_timeout' => 8, // default timeout for writing/reading (in seconds)
             'connect_timeout'    => 10,
             'heartbeat'          => 4
         ]

src/Providers/ServiceProvider.php

Spacing +4 added lines, -4 removed lines

@@ -54,7 +54,7 @@ 
         $this->publishes([
             realpath(
                 dirname(__FILE__)
-            ) . '/../../config/laravel_rabbitmq.php' => config_path('laravel_rabbitmq.php'),
+            ).'/../../config/laravel_rabbitmq.php' => config_path('laravel_rabbitmq.php'),
         ]);
     }
 
@@ -74,7 +74,7 @@ 
 
         $this->app->singleton(
             Container::class,
-            function () use ($config) {
+            function() use ($config) {
                 $container = new ContainerBuilder();
                 return $container->createContainer($config);
             }
@@ -87,7 +87,7 @@ 
     private function registerPublishers()
     {
         // Get "tagged" like Publisher
-        $this->app->singleton(PublisherInterface::class, function (Application $application, $arguments) {
+        $this->app->singleton(PublisherInterface::class, function(Application $application, $arguments) {
             /** @var Container $container */
             $container = $application->make(Container::class);
             if (empty($arguments)) {
@@ -104,7 +104,7 @@ 
     private function registerConsumers()
     {
         // Get "tagged" like Consumers
-        $this->app->singleton(ConsumerInterface::class, function (Application $application, $arguments) {
+        $this->app->singleton(ConsumerInterface::class, function(Application $application, $arguments) {
             /** @var Container $container */
             $container = $application->make(Container::class);
             if (empty($arguments)) {

src/Processor/AbstractMessageProcessor.php

Spacing +4 added lines, -4 removed lines

@@ -40,10 +40,10 @@
             $this->logger->error(
                 sprintf(
                     "Could not process message, got %s from %s in %d for message: %s",
-                    get_class($e) . '-' . $e->getMessage(),
-                    (string)$e->getFile(),
-                    (int)$e->getLine(),
-                    (string)$message->getBody()
+                    get_class($e).'-'.$e->getMessage(),
+                    (string) $e->getFile(),
+                    (int) $e->getLine(),
+                    (string) $message->getBody()
                 )
             );
             $message->delivery_info['channel']->basic_nack($message->delivery_info['delivery_tag'], false, true);

src/Entity/QueueEntity.php

Spacing +9 added lines, -9 removed lines

@@ -235,9 +235,9 @@ 
                 $this->stopConsuming();
                 $this->logger->notice(sprintf(
                     "Stopped consuming: %s in %s:%d",
-                    get_class($e) . ' - ' . $e->getMessage(),
-                    (string)$e->getFile(),
-                    (int)$e->getLine()
+                    get_class($e).' - '.$e->getMessage(),
+                    (string) $e->getFile(),
+                    (int) $e->getLine()
                 ));
                 return 1;
             }
@@ -265,7 +265,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;
@@ -274,7 +274,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;
         }
@@ -290,7 +290,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));
         }
     }
 
@@ -341,7 +341,7 @@ 
     private function registerShutdownHandler()
     {
         $consumer = $this;
-        register_shutdown_function(function () use ($consumer) {
+        register_shutdown_function(function() use ($consumer) {
             $consumer->stopConsuming();
         });
     }
@@ -411,8 +411,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