binary-cube / carrot-mq

src/Component.php

Spacing +2 added lines, -2 removed lines

@@ -44,8 +44,8 @@
      */
     public function __construct(?string $id = null, ?LoggerInterface $logger = null)
     {
-        $this->id     = (! empty($id) ? $id : self::generateUniqueId());
-        $this->logger = (! empty($logger) ? $logger : new NullLogger());
+        $this->id     = (!empty($id) ? $id : self::generateUniqueId());
+        $this->logger = (!empty($logger) ? $logger : new NullLogger());
     }
 
     /**

src/Builder/ContainerBuilder.php

Spacing +6 added lines, -6 removed lines

@@ -130,7 +130,7 @@ 
 
             if (
                 empty($topic['connection']) ||
-                ! $container->connections()->has($topic['connection'])
+                !$container->connections()->has($topic['connection'])
             ) {
                 throw new \RuntimeException(
                     vsprintf(
@@ -182,7 +182,7 @@ 
 
             if (
                 empty($queue['connection']) ||
-                ! $container->connections()->has($queue['connection'])
+                !$container->connections()->has($queue['connection'])
             ) {
                 throw new \RuntimeException(
                     vsprintf(
@@ -229,7 +229,7 @@ 
 
             if (
                 empty($publisher['topic']) ||
-                ! $container->topics()->has($publisher['topic'])
+                !$container->topics()->has($publisher['topic'])
             ) {
                 throw new \RuntimeException(
                     vsprintf(
@@ -276,7 +276,7 @@ 
 
             if (
                 empty($consumer['queue']) ||
-                ! $container->queues()->has($consumer['queue'])
+                !$container->queues()->has($consumer['queue'])
             ) {
                 throw new \RuntimeException(
                     vsprintf(
@@ -295,7 +295,7 @@ 
 
             if (empty($processor)) {
                 $processor = new CallbackProcessor(
-                    function () {
+                    function() {
                         return false;
                     }
                 );
@@ -305,7 +305,7 @@ 
                 $processor = new $processor();
             }
 
-            if (! ($processor instanceof Processor)) {
+            if (!($processor instanceof Processor)) {
                 throw new \LogicException(
                     vsprintf(
                         "Can't create processor, '%s' must extend from %s or its child class.",

src/CarrotMQ.php

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
      */
     public function container(): Container
     {
-        if (! isset($this->container)) {
+        if (!isset($this->container)) {
             $this->build();
         }
 

src/Consumer.php

Spacing +3 added lines, -3 removed lines

@@ -101,7 +101,7 @@ 
         $this->extensions = new ExtensionRepository();
 
         $this->tag = (
-            ! empty($this->tag)
+            !empty($this->tag)
                 ? $this->tag
                 : vsprintf('[host: %s]-[pid: %s]-[queue: %s]', [gethostname(), getmypid(), $this->queue->name()])
         );
@@ -160,7 +160,7 @@ 
         $this->dispatcher(true);
 
         foreach ($this->extensions->all() as $extension) {
-            if (! is_subclass_of($extension, Extension::class)) {
+            if (!is_subclass_of($extension, Extension::class)) {
                 throw new Exception(
                     vsprintf(
                         'The given class, "%s", is not an instance of "%s"',
@@ -243,7 +243,7 @@ 
         */
         $subscription->subscribe(
             $consumer,
-            function ($message, $consumer) use ($context) {
+            function($message, $consumer) use ($context) {
                 return $this->handle($message, $consumer, $context);
             }
         );

src/Support/Laravel/Console/Commands/PublisherCommand.php

Spacing +3 added lines, -3 removed lines

@@ -47,14 +47,14 @@ 
         $route       = (string) $this->input->getOption('route');
         $data        = '';
 
-        if (! $this->carrot->container()->publishers()->has($publisherId)) {
+        if (!$this->carrot->container()->publishers()->has($publisherId)) {
             $this->error(vsprintf('Publisher "%s" not found.', [$publisherId]));
             return 0;
         }
 
         $publisher = $this->carrot->container()->publishers()->get($publisherId);
 
-        while (! feof(STDIN)) {
+        while (!feof(STDIN)) {
             $data .= fread(STDIN, 8192);
         }
 
@@ -64,7 +64,7 @@ 
 
         $message = MessageBuilder::create()->body($data)->build();
 
-        if (! empty($route)) {
+        if (!empty($route)) {
             $message->setRoutingKey($route);
         }
 

src/Support/Laravel/Console/Commands/ConsumerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
     {
         $consumerId = (string) $this->input->getArgument('consumer');
 
-        if (! $this->carrot->container()->consumers()->has($consumerId)) {
+        if (!$this->carrot->container()->consumers()->has($consumerId)) {
             $this->error(vsprintf('Consumer "%s" not found.', [$consumerId]));
             return 0;
         }

src/Support/Laravel/Console/Commands/PurgeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
     {
         $queueId = (string) $this->input->getArgument('queue');
 
-        if (! $this->carrot->container()->queues()->has($queueId)) {
+        if (!$this->carrot->container()->queues()->has($queueId)) {
             $this->error(vsprintf('Queue "%s" not found.', [$queueId]));
             return 0;
         }

src/Support/Laravel/CarrotMQServiceProvider.php

Spacing +5 added lines, -5 removed lines

@@ -54,17 +54,17 @@ 
     {
         $config = config('carrot_mq', []);
 
-        if (! is_array($config)) {
+        if (!is_array($config)) {
             throw new \RuntimeException(
                 'Invalid configuration provided for CarrotMQ-Laravel!'
             );
         }
 
-        $this->app->bind('carrot.mq', function (Application $app) {
+        $this->app->bind('carrot.mq', function(Application $app) {
             return app(CarrotMQ::class);
         });
 
-        $this->app->singleton(CarrotMQ::class, function (Application $app, $arguments) use ($config) {
+        $this->app->singleton(CarrotMQ::class, function(Application $app, $arguments) use ($config) {
             $logger = $app->make(LoggerInterface::class);
             $carrot = new CarrotMQ($config, $logger);
 
@@ -77,7 +77,7 @@ 
      */
     protected function prepareCommands()
     {
-        if (! $this->app->runningInConsole()) {
+        if (!$this->app->runningInConsole()) {
             return;
         }
 
@@ -98,7 +98,7 @@ 
      */
     protected function getConfigFile()
     {
-        return (__DIR__ . '/config/carrot_mq.php');
+        return (__DIR__.'/config/carrot_mq.php');
     }
 
 }

src/Support/DispatcherAwareTrait.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
      */
     protected function dispatcher(bool $fresh = false): EventDispatcher
     {
-        if ($fresh || ! isset($this->dispatcher)) {
+        if ($fresh || !isset($this->dispatcher)) {
             $this->dispatcher = new EventDispatcher();
         }