Gendoria / command-queue-bundle

src/Gendoria/CommandQueueBundle/CommandQueue/ContainerAwareProcessorFactory.php

Spacing +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
      */
     public function hasProcessor($commandClassName)
     {
-        return parent::hasProcessor($commandClassName) || array_key_exists($commandClassName, $this->serviceIds) ;
+        return parent::hasProcessor($commandClassName) || array_key_exists($commandClassName, $this->serviceIds);
     }
     
     /**

src/Gendoria/CommandQueueBundle/DependencyInjection/Configuration.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
                 ->isRequired()
                 ->requiresAtLeastOneElement()
                 ->validate()
-                ->ifTrue(function (array $value) {
+                ->ifTrue(function(array $value) {
                         return !array_key_exists('default', $value);
                 })
                     ->thenInvalid('Default service not present')
@@ -56,7 +56,7 @@ 
                         ->scalarNode('send_driver')
                             ->isRequired()
                             ->validate()
-                            ->ifTrue(function ($value) {
+                            ->ifTrue(function($value) {
                                     return !preg_match('/^@[a-zA-Z\.\-0-9\_]+$/', $value);
                             })
                                 ->thenInvalid('Malformed service ID "%s"')

src/Gendoria/CommandQueueBundle/DependencyInjection/Pass/PoolsPass.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
                 ));
             }
             if (!$container->hasDefinition($sendServiceId)) {
-                throw new InvalidArgumentException('Non existing send driver service provided: ' . $poolData['send_driver'].'.');
+                throw new InvalidArgumentException('Non existing send driver service provided: '.$poolData['send_driver'].'.');
             }
             $sendDriverReflection = new ReflectionClass($container->getDefinition($sendServiceId)->getClass());
             if (!$sendDriverReflection->implementsInterface(SendDriverInterface::class)) {
@@ -86,7 +86,7 @@ 
     private function setupSingleQueueManager($id, Definition $def, array $tags, array $pools)
     {
         if (count($tags) > 1) {
-            throw new InvalidArgumentException('Only single ' . self::QUEUE_MANAGER_TAG . ' tag possible on service ' . $id.'.');
+            throw new InvalidArgumentException('Only single '.self::QUEUE_MANAGER_TAG.' tag possible on service '.$id.'.');
         }
         if (!empty($tags[0]['pool'])) {
             $poolName = $tags[0]['pool'];