added schema onfiguration for batch_consumer

Author: Bogdan Rancichi

DependencyInjection/Configuration.php

@@ -33,6 +33,7 @@ public function getConfigTreeBuilder()
         $this->addConsumers($rootNode);
         $this->addMultipleConsumers($rootNode);
         $this->addDynamicConsumers($rootNode);
+        $this->addBatchConsumers($rootNode);
         $this->addAnonConsumers($rootNode);
         $this->addRpcClients($rootNode);
         $this->addRpcServers($rootNode);
@@ -220,6 +221,42 @@ protected function addDynamicConsumers(ArrayNodeDefinition $node)
         ;
     }
 
+    /**
+     * @param   ArrayNodeDefinition     $node
+     *
+     * @return  void
+     */
+    protected function addBatchConsumers(ArrayNodeDefinition $node)
+    {
+        $node
+            ->children()
+                ->arrayNode('batch_consumers')
+                    ->canBeUnset()
+                    ->useAttributeAsKey('key')
+                    ->prototype('array')
+                        ->append($this->getExchangeConfiguration())
+                        ->children()
+                            ->scalarNode('connection')->defaultValue('default')->end()
+                            ->scalarNode('callback')->isRequired()->end()
+                            ->scalarNode('idle_timeout')->end()
+                            ->scalarNode('timeout_wait')->defaultValue(3)->end()
+                            ->scalarNode('idle_timeout_exit_code')->end()
+                            ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
+                            ->arrayNode('qos_options')
+                                ->children()
+                                    ->scalarNode('prefetch_size')->defaultValue(0)->end()
+                                    ->scalarNode('prefetch_count')->defaultValue(2)->end()
+                                    ->booleanNode('global')->defaultFalse()->end()
+                                ->end()
+                            ->end()
+                            ->scalarNode('enable_logger')->defaultFalse()->end()
+                        ->end()
+                    ->end()
+                ->end()
+            ->end()
+        ;
+    }
+
     protected function addAnonConsumers(ArrayNodeDefinition $node)
     {
         $node