Server Group

Author: pierophp

src/Core/SupervisorGenerator.php

@@ -26,6 +26,16 @@ public function generate()
             return $name !== 'sync';
         });
 
+        $hostname = gethostname();
+
+        $configs = array_filter($configs, function ($config) use ($hostname) {
+            if (!$config->server_group) {
+                return true;
+            }
+            
+            return substr($hostname, 0, strlen($config->server_group)) === $config->server_group;
+        });
+
         foreach ($configs as $config) {
             $connectionName = config('queue.default');
             if ($config->connection && $config->connection !== 'default') {

src/migrations/2019_09_23_153409_queue_config_add_server_group.php

@@ -0,0 +1,32 @@
+<?php
+
+use Illuminate\Support\Facades\Schema;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Database\Migrations\Migration;
+
+class QueueConfigAddServerGroup extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::table('queue_config', function (Blueprint $table) {
+            $table->string('server_group')->nullable();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::table('queue_config', function (Blueprint $table) {
+            $table->dropColumn('server_group');
+        });
+    }
+}