implements keep_alive option for batch consumers

Author: christianmeller

DependencyInjection/Configuration.php

@@ -272,6 +272,7 @@ protected function addBatchConsumers(ArrayNodeDefinition $node)
                             ->scalarNode('idle_timeout')->end()
                             ->scalarNode('timeout_wait')->defaultValue(3)->end()
                             ->scalarNode('idle_timeout_exit_code')->end()
+                            ->scalarNode('keep_alive')->defaultFalse()->end()
                             ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
                             ->arrayNode('qos_options')
                                 ->children()

DependencyInjection/OldSoundRabbitMqExtension.php

@@ -418,6 +418,10 @@ protected function loadBatchConsumers()
                 $definition->addMethodCall('disableAutoSetupFabric');
             }
 
+            if ($consumer['keep_alive']) {
+                $definition->addMethodCall('keepAlive');
+            }
+
             $this->injectConnection($definition, $consumer['connection']);
             if ($this->collectorEnabled) {
                 $this->injectLoggedChannel($definition, $key, $consumer['connection']);

README.md

@@ -810,8 +810,11 @@ batch_consumers:
         timeout_wait:     5
         auto_setup_fabric: false
         idle_timeout_exit_code: -2
+        keep_alive: false
 ```
 
+*Note*: If the `keep_alive` option is set to `true`, `idle_timeout_exit_code` will be ignored and the consumer process continues.
+
 You can implement a batch consumer that will acknowledge all messages in one return or you can have control on what message to acknoledge.
 
 ```php

RabbitMq/BatchConsumer.php

@@ -24,6 +24,11 @@ final class BatchConsumer extends BaseAmqp implements DequeuerInterface
      */
     private $idleTimeout = 0;
 
+    /**
+     * @var bool
+     */
+    private $keepAlive = false;
+
     /**
      * @var int
      */
@@ -84,6 +89,8 @@ public function consume()
             } catch (AMQPTimeoutException $e) {
                 if (!$this->isEmptyBatch()) {
                     $this->batchConsume();
+                } elseif ($this->keepAlive === true) {
+                    continue;
                 } elseif (null !== $this->getIdleTimeoutExitCode()) {
                     return $this->getIdleTimeoutExitCode();
                 } else {
@@ -399,6 +406,18 @@ public function setIdleTimeoutExitCode($idleTimeoutExitCode)
         return $this;
     }
 
+    /**
+     * keepAlive
+     *
+     * @return $this
+     */
+    public function keepAlive()
+    {
+        $this->keepAlive = true;
+
+        return $this;
+    }
+
     /**
      * Purge the queue
      */