Merge pull request #163 from jamesmoey/add_qos_options_rpc_server

Add qos_options configurable to rpc_servers

Author: videlalvaro

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

@@ -249,7 +249,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);
         }
     }

README.md

@@ -375,6 +375,7 @@ rpc_servers:
     random_int:
         connection: default
         callback:   random_int_server
+        qos_options: {prefetch_size: 0, prefetch_count: 1, global: false}
 ```
 
 Here we have a very useful server: it returns random integers to its clients. The callback used to process the request will be the __random\_int\_server__ service. Now let's see how to invoke it from our controllers.