binary-cube / carrot-mq

src/Driver/AmqpDriver.php

Spacing +3 added lines, -3 removed lines

@@ -125,7 +125,7 @@ 
 
         $extension = $config['extension'];
 
-        if (empty($extension) || ! isset($this->extensions[$extension])) {
+        if (empty($extension) || !isset($this->extensions[$extension])) {
             throw new InvalidConfigException(
                 vsprintf(
                     'The given extension "%s" is not supported. Extensions supported are "%s"',
@@ -146,14 +146,14 @@ 
         // Remove the attributes with null value.
         $config = array_filter(
             $config,
-            function ($value) {
+            function($value) {
                 return null !== $value;
             }
         );
 
         $class = $this->extensions[$extension];
 
-        if (! class_exists($class)) {
+        if (!class_exists($class)) {
             throw new ClassNotFoundException(vsprintf('Class %s not found.', [$class]));
         }
 

src/Entity/Topic.php

Spacing +5 added lines, -5 removed lines

@@ -102,12 +102,12 @@ 
                 $properties,
                 array_filter(
                     $this->config,
-                    function ($value) {
+                    function($value) {
                         return $value === true;
                     }
                 )
             ),
-            function ($a, $b) {
+            function($a, $b) {
                 return ($a | $b);
             },
             (AmqpTopic::FLAG_NOPARAM)
@@ -116,7 +116,7 @@ 
         $exchange->setType($this->config['type']);
         $exchange->setFlags($flags);
 
-        if (! empty($this->config['arguments'])) {
+        if (!empty($this->config['arguments'])) {
             $exchange->setArguments($this->config['arguments']);
         }
 
@@ -166,14 +166,14 @@ 
             try {
                 $bind = Collection::make($default)->merge($bind)->all();
 
-                if (! empty($bind['queue'])) {
+                if (!empty($bind['queue'])) {
                     $queue     = $this->context()->createQueue($bind['queue']);
                     $queueBind = new AmqpBind($this->model(), $queue, $bind['routing_key']);
 
                     $this->context()->bind($queueBind);
                 }
 
-                if (! empty($bind['topic'])) {
+                if (!empty($bind['topic'])) {
                     $topic        = $this->context()->createTopic($bind['topic']);
                     $exchangeBind = new AmqpBind($this->model(), $topic, $bind['routing_key']);
 

src/Entity/Queue.php

Spacing +3 added lines, -3 removed lines

@@ -95,12 +95,12 @@ 
                 $properties,
                 array_filter(
                     $this->config,
-                    function ($value) {
+                    function($value) {
                         return $value === true;
                     }
                 )
             ),
-            function ($a, $b) {
+            function($a, $b) {
                 return ($a | $b);
             },
             (AmqpQueue::FLAG_NOPARAM)
@@ -108,7 +108,7 @@ 
 
         $queue->setFlags($flags);
 
-        if (! empty($this->config['arguments'])) {
+        if (!empty($this->config['arguments'])) {
             $queue->setArguments($this->config['arguments']);
         }
 

src/Publisher.php

Spacing +1 added lines, -1 removed lines

@@ -154,7 +154,7 @@
      */
     protected function wireProducer(bool $refresh = false): Amqp\AmqpProducer
     {
-        if ($refresh || ! isset($this->producer)) {
+        if ($refresh || !isset($this->producer)) {
             $context        = $this->topic->connection()->context(true);
             $this->producer = $context->createProducer();
 

src/Extension/SignalExtension.php

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
      */
     public function onStart(Event\Consumer\Start $event): void
     {
-        if (! extension_loaded('pcntl')) {
+        if (!extension_loaded('pcntl')) {
             throw new Exception('The pcntl extension is required in order to catch signals.');
         }