From 0c6cbae561f21a6ec054e617b493d2d4847d5b1f Mon Sep 17 00:00:00 2001 From: Sebastiaan Hilbers Date: Mon, 12 Feb 2018 13:34:44 +0100 Subject: [PATCH] hardcoded queue prefix as constant --- src/Driver/PhpRedisDriver.php | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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; } }