Graceful max execution options is now available for multiple consumers too (#468)

Author: chernecov

DependencyInjection/Configuration.php

@@ -194,6 +194,13 @@ protected function addMultipleConsumers(ArrayNodeDefinition $node)
                         ->scalarNode('idle_timeout')->end()
                         ->scalarNode('idle_timeout_exit_code')->end()
                         ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
+                        ->arrayNode('graceful_max_execution')
+                            ->canBeUnset()
+                            ->children()
+                                ->integerNode('timeout')->end()
+                                ->integerNode('exit_code')->defaultValue(0)->end()
+                            ->end()
+                        ->end()
                         ->append($this->getMultipleQueuesConfiguration())
                         ->arrayNode('qos_options')
                             ->canBeUnset()

DependencyInjection/OldSoundRabbitMqExtension.php

@@ -289,6 +289,16 @@ protected function loadMultipleConsumers()
             if (isset($consumer['idle_timeout_exit_code'])) {
                 $definition->addMethodCall('setIdleTimeoutExitCode', array($consumer['idle_timeout_exit_code']));
             }
+            if (isset($consumer['graceful_max_execution'])) {
+                $definition->addMethodCall(
+                    'setGracefulMaxExecutionDateTimeFromSecondsInTheFuture',
+                    array($consumer['graceful_max_execution']['timeout'])
+                );
+                $definition->addMethodCall(
+                    'setGracefulMaxExecutionTimeoutExitCode',
+                    array($consumer['graceful_max_execution']['exit_code'])
+                );
+            }
             if (!$consumer['auto_setup_fabric']) {
                 $definition->addMethodCall('disableAutoSetupFabric');
             }