Gendoria / command-queue-bundle

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'];

src/Gendoria/CommandQueueBundle/DependencyInjection/Configuration.php

Spacing +2 added lines, -2 removed lines

@@ -52,7 +52,7 @@ 
                 ->arrayNode('pools')
                     ->requiresAtLeastOneElement()
                     ->validate()
-                    ->ifTrue(function (array $value) {
+                    ->ifTrue(function(array $value) {
                             return !array_key_exists('default', $value);
                     })
                         ->thenInvalid('Default service not present')
@@ -62,7 +62,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/CommandProcessorPass.php

Spacing +1 added lines, -1 removed lines

@@ -91,7 +91,7 @@
         }
         $refl = new ReflectionClass($def->getClass());
         if (!$refl->implementsInterface(CommandProcessorInterface::class)) {
-            throw new InvalidArgumentException(sprintf('The service "%s" has to implement ' . CommandProcessorInterface::class . '.', $id));
+            throw new InvalidArgumentException(sprintf('The service "%s" has to implement '.CommandProcessorInterface::class.'.', $id));
         }
     }
 }

src/Gendoria/CommandQueueBundle/ProcessorFactory/ContainerAwareProcessorFactory.php

Doc Comments +1 added lines

@@ -61,6 +61,7 @@
     
     /**
      * {@inheritdoc}
+     * @param string $commandClassName
      */
     public function hasProcessor($commandClassName)
     {

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);
     }
     
     /**