fix: connection name for used handler

Author: michalsn

src/Handlers/BaseHandler.php

@@ -30,6 +30,8 @@ abstract class BaseHandler
     protected QueueConfig $config;
     protected ?string $priority = null;
 
+    abstract public function name(): string;
+
     abstract public function push(string $queue, string $job, array $data): bool;
 
     abstract public function pop(string $queue, array $priorities): ?QueueJob;
@@ -144,7 +146,7 @@ protected function logFailed(QueueJob $queueJob, Throwable $err): bool
             "file: {$err->getFile()}:{$err->getLine()}";
 
         $queueJobFailed = new QueueJobFailed([
-            'connection' => 'database',
+            'connection' => $this->name(),
             'queue'      => $queueJob->queue,
             'payload'    => $queueJob->payload,
             'priority'   => $queueJob->priority,

src/Handlers/DatabaseHandler.php

@@ -33,6 +33,14 @@ public function __construct(protected QueueConfig $config)
         $this->jobModel = model(QueueJobModel::class, true, $connection);
     }
 
+    /**
+     * Name of the handler.
+     */
+    public function name(): string
+    {
+        return 'database';
+    }
+
     /**
      * Add job to the queue.
      *

src/Handlers/PredisHandler.php

@@ -38,6 +38,14 @@ public function __construct(protected QueueConfig $config)
         }
     }
 
+    /**
+     * Name of the handler.
+     */
+    public function name(): string
+    {
+        return 'predis';
+    }
+
     /**
      * Add job to the queue.
      */

src/Handlers/RedisHandler.php

@@ -53,6 +53,14 @@ public function __construct(protected QueueConfig $config)
         }
     }
 
+    /**
+     * Name of the handler.
+     */
+    public function name(): string
+    {
+        return 'redis';
+    }
+
     /**
      * Add job to the queue.
      *

tests/PredisHandlerTest.php

@@ -182,7 +182,7 @@ public function testFailedAndKeepJob(): void
 
         $this->seeInDatabase('queue_jobs_failed', [
             'id'         => 2,
-            'connection' => 'database',
+            'connection' => 'predis',
             'queue'      => 'queue1',
         ]);
     }
@@ -206,7 +206,7 @@ public function testFailedAndDontKeepJob(): void
 
         $this->dontSeeInDatabase('queue_jobs_failed', [
             'id'         => 2,
-            'connection' => 'database',
+            'connection' => 'predis',
             'queue'      => 'queue1',
         ]);
     }

tests/RedisHandlerTest.php

@@ -166,7 +166,7 @@ public function testFailedAndKeepJob(): void
 
         $this->seeInDatabase('queue_jobs_failed', [
             'id'         => 2,
-            'connection' => 'database',
+            'connection' => 'redis',
             'queue'      => 'queue1',
         ]);
     }
@@ -187,7 +187,7 @@ public function testFailedAndDontKeepJob(): void
 
         $this->dontSeeInDatabase('queue_jobs_failed', [
             'id'         => 2,
-            'connection' => 'database',
+            'connection' => 'redis',
             'queue'      => 'queue1',
         ]);
     }