Merge pull request #37 from aloware/change-fair-signal-pattern

Change Fair Signal Pattern
aloware · Oct 20, 2022 · cb1345f · cb1345f
2 parents 191e203 + fec04b1
commit cb1345f
Show file tree

Hide file tree

Showing 3 changed files with 345 additions and 13 deletions.
diff --git a/src/Interfaces/RepositoryInterface.php b/src/Interfaces/RepositoryInterface.php
@@ -65,7 +65,7 @@ public function recoverStuckJobs();
 
     public function getConnection();
 
-    public function countFairSignals($queue);
+    public function countFairSignals($queue, $partition);
 
     public  function countAllJobs($queue);
 

diff --git a/src/Repositories/RedisKeys.php b/src/Repositories/RedisKeys.php
@@ -25,16 +25,25 @@ private function queueKey($queue, $prefix = '')
         );
     }
 
-    private function fairSignalKey($queue)
+    /**
+     * Get Fair Signal Redis Key Name
+     *
+     * @param string $queue
+     * @param string $partition
+     *
+     * @return string
+     */
+    private function fairSignalKey($queue, $partition)
     {
         $signal_key_prefix_for_horizon = config('fair-queue.signal_key_prefix_for_horizon');
         $horizon_prefix = config('horizon.prefix');
 
         return sprintf(
-            '%s%s%s:[0-9]*',
+            '%s%s%s:%s:[0-9]*',
             $horizon_prefix,
             $signal_key_prefix_for_horizon,
-            $queue
+            $queue,
+            $partition,
         );
     }