Merge pull request #9 from RonRademaker/configure-max-messages

feature (worker configuration): add config option to define max messages

Author: Phobetor

DependencyInjection/Configuration.php

@@ -73,6 +73,7 @@ protected function addCommands(ArrayNodeDefinition $node)
                     ->children()
                         ->scalarNode('rabbitmq_consumer')->defaultValue('rabbitmq:consumer -m %%1$d %%2$s')->end()
                         ->scalarNode('rabbitmq_multiple_consumer')->defaultValue('rabbitmq:multiple-consumer -m %%1$d %%2$s')->end()
+                        ->integerNode('max_messages')->defaultValue('250')->end()
                     ->end()
                 ->end()
             ->end()

Services/RabbitMqSupervisor.php

@@ -100,10 +100,10 @@ public function build()
         }
 
         // generate program configuration files for all consumers
-        $this->generateWorkerConfigurations(array_keys($this->consumers), $this->commands['rabbitmq_consumer']);
+        $this->generateWorkerConfigurations(array_keys($this->consumers), $this->commands['rabbitmq_consumer'], $this->commands['max_messages']);
 
         // generate program configuration files for all multiple consumers
-        $this->generateWorkerConfigurations(array_keys($this->multipleConsumers), $this->commands['rabbitmq_multiple_consumer']);
+        $this->generateWorkerConfigurations(array_keys($this->multipleConsumers), $this->commands['rabbitmq_multiple_consumer'], $this->commands['max_messages']);
 
         // start supervisor and reload configuration
         $this->start();
@@ -252,7 +252,7 @@ public function generateSupervisorConfiguration()
         );
     }
 
-    private function generateWorkerConfigurations($names, $command)
+    private function generateWorkerConfigurations($names, $command, $maxMessages = 250)
     {
         if (0 === strpos($_SERVER["SCRIPT_FILENAME"], '/')) {
             $executablePath = $_SERVER["SCRIPT_FILENAME"];
@@ -266,7 +266,7 @@ private function generateWorkerConfigurations($names, $command)
                 $name,
                 array(
                     'name' => $name,
-                    'command' => sprintf($command, 250, $name),
+                    'command' => sprintf($command, $maxMessages, $name),
                     'executablePath' => $executablePath,
                     'workerOutputLog' => $this->paths['worker_output_log_file'],
                     'workerErrorLog' => $this->paths['worker_error_log_file'],