Update: worker name can be initialized at registration time

cloudtay · Jan 17, 2025 · ef8c780 · ef8c780
1 parent f786ec5
commit ef8c780
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 4 deletions.
diff --git a/src/Worker/Manager.php b/src/Worker/Manager.php
@@ -59,11 +59,13 @@ class Manager
      */
     public function addWorker(Worker $worker): void
     {
-        if (isset($this->workers[$worker->getName()])) {
-            Output::warning('Worker name already exists');
+        $worker->register($this);
+        $workerName = $worker->getName();
+        if (isset($this->workers[$workerName])) {
+            Output::warning("Worker {$workerName} already exists");
             return;
         }
-        $this->workers[$worker->getName()] = $worker;
+        $this->workers[$workerName] = $worker;
     }
 
     /**

diff --git a/src/Worker/Worker.php b/src/Worker/Worker.php
@@ -80,13 +80,22 @@ abstract class Worker
     /**
      * @var string
      */
-    protected string $name = 'worker';
+    protected string $name;
 
     /**
      * @var array
      */
     private array $queue = [];
 
+    /**
+     *
+     */
+    public function __construct()
+    {
+        $this->name  = static::class;
+        $this->count = 1;
+    }
+
     /**
      * Send instructions to the specified Worker
      *