needle-project / laravel-rabbitmq

src/Entity/AMQPEntityInterface.php

Doc Comments +1 added lines

@@ -33,6 +33,7 @@
 
     /**
      * Reconnect the entity
+     * @return void
      */
     public function reconnect();
 }

src/Command/SetupCommand.php

Spacing +24 added lines, -24 removed lines

@@ -29,7 +29,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';
 
     /**
@@ -64,8 +64,8 @@ 
             $this->output->writeln(
                 sprintf(
                     "Deleting <info>%s</info> <fg=yellow>%s</>",
-                    (string)($entity instanceof QueueEntity) ? 'QUEUE' : 'EXCHANGE',
-                    (string)$entity->getAliasName()
+                    (string) ($entity instanceof QueueEntity) ? 'QUEUE' : 'EXCHANGE',
+                    (string) $entity->getAliasName()
                 )
             );
             $entity->delete();
@@ -75,10 +75,10 @@ 
         $this->output->writeln(
             sprintf(
                 "Created <info>%s</info> <fg=yellow>%s</> for %s [<fg=yellow>%s</>]",
-                (string)($entity instanceof QueueEntity) ? 'QUEUE' : 'EXCHANGE',
-                (string)$entity->getAliasName(),
-                (string)$type,
-                (string)$resourceName
+                (string) ($entity instanceof QueueEntity) ? 'QUEUE' : 'EXCHANGE',
+                (string) $entity->getAliasName(),
+                (string) $type,
+                (string) $resourceName
             )
         );
     }
@@ -100,9 +100,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()
                     )
                 );
                 $entity->reconnect();
@@ -118,9 +118,9 @@ 
                 $this->output->error(
                     sprintf(
                         "Could not create entity %s for consumer [%s], got:\n%s",
-                        (string)$entity->getAliasName(),
-                        (string)$publisherName,
-                        (string)$e->getMessage()
+                        (string) $entity->getAliasName(),
+                        (string) $publisherName,
+                        (string) $e->getMessage()
                     )
                 );
                 $entity->reconnect();
@@ -135,8 +135,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) {
@@ -144,9 +144,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()
                     )
                 );
             }
@@ -159,8 +159,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) {
@@ -168,13 +168,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;
     }
 }