We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e4ca25a commit 0c6cbaeCopy full SHA for 0c6cbae
1 file changed
src/Driver/PhpRedisDriver.php
@@ -11,6 +11,8 @@
11
*/
12
class PhpRedisDriver implements \Bernard\Driver
13
{
14
+ const QUEUE_PREFIX = 'queue:';
15
+
16
protected $redis;
17
18
/**
@@ -42,7 +44,7 @@ public function createQueue($queueName)
42
44
43
45
public function countMessages($queueName)
46
- return $this->redis->lLen('queue:' . $queueName);
47
+ return $this->redis->lLen(self::QUEUE_PREFIX . $queueName);
48
}
49
50
@@ -114,6 +116,6 @@ public function info()
114
116
115
117
protected function resolveKey($queueName)
118
- return 'queue:' . $queueName;
119
+ return self::QUEUE_PREFIX . $queueName;
120
121
0 commit comments