group consumers so supervisor sends signals in parallel

Phobetor · Oct 31, 2021 · 403658f · 403658f
1 parent 7029eee
commit 403658f
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/Services/RabbitMqSupervisor.php b/Services/RabbitMqSupervisor.php
@@ -307,6 +307,14 @@ public function generateSupervisorConfiguration()
             ),
             'include' => array(
                 'files' => sprintf('%s*.conf', $this->paths['worker_configuration_directory'])
+            ),
+            'group:all' => array(
+                'programs' => implode(',', array_merge(
+                    array_keys($this->consumers),
+                    array_keys($this->multipleConsumers),
+                    array_keys($this->batchConsumers),
+                    array_keys($this->rpcServers)
+                ))
             )
         ));
         file_put_contents(