Add qos_options configurable to rpc_servers

Author: James Moey

DependencyInjection/Configuration.php

@@ -89,6 +89,14 @@ public function getConfigTreeBuilder()
                         ->children()
                             ->scalarNode('connection')->defaultValue('default')->end()
                             ->scalarNode('callback')->isRequired()->end()
+                            ->arrayNode('qos_options')
+                                ->canBeUnset()
+                                ->children()
+                                    ->scalarNode('prefetch_size')->defaultValue(0)->end()
+                                    ->scalarNode('prefetch_count')->defaultValue(0)->end()
+                                    ->booleanNode('global')->defaultFalse()->end()
+                                ->end()
+                            ->end()
                         ->end()
                     ->end()
                 ->end()

DependencyInjection/OldSoundRabbitMqExtension.php

@@ -250,7 +250,13 @@ protected function loadRpcServers()
             if ($this->collectorEnabled) {
                 $this->injectLoggedChannel($definition, $key, $server['connection']);
             }
-
+            if (array_key_exists('qos_options', $server)) {
+                $definition->addMethodCall('setQosOptions', array(
+                    $server['qos_options']['prefetch_size'],
+                    $server['qos_options']['prefetch_count'],
+                    $server['qos_options']['global']
+                ));
+            }
             $this->container->setDefinition(sprintf('old_sound_rabbit_mq.%s_server', $key), $definition);
         }
     }