queue consumer options

Author: ASKozienko

pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php

@@ -112,14 +112,14 @@ public function load(array $configs, ContainerBuilder $container)
 
         // configure queue consumer
         $container->getDefinition('enqueue.consumption.queue_consumer')
-            ->setArgument(2, $config['consumption']['idle_timeout'])
-            ->setArgument(3, $config['consumption']['receive_timeout'])
+            ->replaceArgument(2, $config['consumption']['idle_timeout'])
+            ->replaceArgument(3, $config['consumption']['receive_timeout'])
         ;
 
         if ($container->hasDefinition('enqueue.client.queue_consumer')) {
             $container->getDefinition('enqueue.client.queue_consumer')
-                ->setArgument(2, $config['consumption']['idle_timeout'])
-                ->setArgument(3, $config['consumption']['receive_timeout'])
+                ->replaceArgument(2, $config['consumption']['idle_timeout'])
+                ->replaceArgument(3, $config['consumption']['receive_timeout'])
             ;
         }
 

pkg/enqueue-bundle/Resources/config/client.yml

@@ -85,6 +85,8 @@ services:
         arguments:
             - '@enqueue.transport.context'
             - '@enqueue.consumption.extensions'
+            - ~
+            - ~
 
     enqueue.client.consume_messages_command:
         class: 'Enqueue\Symfony\Client\ConsumeMessagesCommand'

pkg/enqueue-bundle/Resources/config/services.yml

@@ -10,6 +10,8 @@ services:
         arguments:
             - '@enqueue.transport.context'
             - '@enqueue.consumption.extensions'
+            - ~
+            - ~
 
     enqueue.command.consume_messages:
         class: 'Enqueue\Symfony\Consumption\ContainerAwareConsumeMessagesCommand'