Merge pull request #354 from bashilbers/patch-3

hardcoded queue prefix as constant
bernardphp · Feb 13, 2018 · 1144b4d · 1144b4d
2 parents e4ca25a + 0c6cbae
commit 1144b4d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/Driver/PhpRedisDriver.php b/src/Driver/PhpRedisDriver.php
@@ -11,6 +11,8 @@
  */
 class PhpRedisDriver implements \Bernard\Driver
 {
+    const QUEUE_PREFIX = 'queue:';
+
     protected $redis;
 
     /**
@@ -42,7 +44,7 @@ public function createQueue($queueName)
      */
     public function countMessages($queueName)
     {
-        return $this->redis->lLen('queue:' . $queueName);
+        return $this->redis->lLen(self::QUEUE_PREFIX . $queueName);
     }
 
     /**
@@ -114,6 +116,6 @@ public function info()
      */
     protected function resolveKey($queueName)
     {
-        return 'queue:' . $queueName;
+        return self::QUEUE_PREFIX . $queueName;
     }
 }