From e850510929335b7fa09e724707be3de3ace28f79 Mon Sep 17 00:00:00 2001 From: Alexander Kozienko Date: Fri, 8 Sep 2017 17:31:22 +0300 Subject: [PATCH] queue consumer options --- .../DependencyInjection/EnqueueExtension.php | 8 ++++---- pkg/enqueue-bundle/Resources/config/client.yml | 2 ++ pkg/enqueue-bundle/Resources/config/services.yml | 2 ++ 3 files changed, 8 insertions(+), 4 deletions(-) diff --git a/pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php b/pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php index 42e37ce33..7d1221dcd 100644 --- a/pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php +++ b/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']) ; } diff --git a/pkg/enqueue-bundle/Resources/config/client.yml b/pkg/enqueue-bundle/Resources/config/client.yml index f7bf69ae8..f8a2b0c83 100644 --- a/pkg/enqueue-bundle/Resources/config/client.yml +++ b/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' diff --git a/pkg/enqueue-bundle/Resources/config/services.yml b/pkg/enqueue-bundle/Resources/config/services.yml index 66dc0d1a8..1d13655d7 100644 --- a/pkg/enqueue-bundle/Resources/config/services.yml +++ b/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'