Rebase v1.9.1 with master

alterrabr · Jun 14, 2021 · 434dafd · 434dafd
1 parent 9ba8c82
commit 434dafd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Comet.php b/src/Comet.php
@@ -269,8 +269,9 @@ public function run()
             $worker->onWorkerStart = self::$init;
 
         // Init JOB workers
+        $counter = 0;
         foreach (self::$jobs as $job) {
-	        $w = new Worker('text://' . self::$host . ':' . 65432);
+	        $w = new Worker('text://' . self::$host . ':' . strval(65432 + $counter++));
     	    $w->count = $job['workers'];
         	$w->name = 'Comet v' . self::VERSION .' [job] ' . $job['name'];
         	$w->onWorkerStart = function() use ($job) {