diff --git a/src/Driver/PhpRedisDriver.php b/src/Driver/PhpRedisDriver.php index 20a83f59..ebba970b 100644 --- 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; } }