Async commands extended

Author: uro

DependencyInjection/Configuration.php

@@ -73,6 +73,11 @@ private function getAsyncCommandsConfiguration(): ArrayNodeDefinition
         }
 
         return (new ArrayNodeDefinition('async_commands'))
+            ->children()
+                ->booleanNode('enabled')->defaultFalse()->end()
+                ->integerNode('timeout')->min(0)->defaultValue(60)->end()
+                ->scalarNode('prefix')->defaultValue('')->end()
+            ->end()
             ->addDefaultsIfNotSet()
             ->canBeEnabled()
         ;

DependencyInjection/EnqueueExtension.php

@@ -291,14 +291,18 @@ private function loadReplyExtension(array $config, ContainerBuilder $container):
 
     private function loadAsyncCommands(array $config, ContainerBuilder $container): void
     {
-        $configNames = [];
+        $configs = [];
         foreach ($config as $name => $modules) {
             if (false === empty($modules['async_commands']['enabled'])) {
-                $configNames[] = $name;
+                $configs[] = [
+                    'name' => $name,
+                    'timeout' => $modules['async_commands']['timeout'],
+                    'prefix' => $modules['async_commands']['prefix'],
+                ];
             }
         }
 
-        if (false == $configNames) {
+        if (false == $configs) {
             return;
         }
 
@@ -307,7 +311,7 @@ private function loadAsyncCommands(array $config, ContainerBuilder $container):
         }
 
         $extension = new AsyncCommandExtension();
-        $extension->load(['clients' => $configNames], $container);
+        $extension->load(['clients' => $configs], $container);
     }
 
     private function loadMessageQueueCollector(array $config, ContainerBuilder $container)

Tests/Functional/App/config/config.yml

@@ -28,7 +28,10 @@ enqueue:
             traceable_producer: true
         job: true
         async_events: true
-        async_commands: true
+        async_commands:
+            enabled: true
+            timeout: 60
+            prefix: ''
 
 services:
     test_enqueue.client.default.traceable_producer:
@@ -122,4 +125,4 @@ services:
     enqueue.events.async_listener:
         class: 'Enqueue\Bundle\Tests\Functional\App\AsyncListener'
         public: true
-        arguments: ['@enqueue.client.default.producer', '@enqueue.events.registry']
+        arguments: ['@enqueue.client.default.producer', '@enqueue.events.registry']