FEATURE: Implement countReserved, countFailed and countReady (#9)

Comply with next major doctrine-common QueueInterface
Flowpack · May 30, 2018 · 97c8415 · 97c8415
1 parent c5045ee
commit 97c8415
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 3 deletions.
diff --git a/Classes/Queue/RedisQueue.php b/Classes/Queue/RedisQueue.php
@@ -193,14 +193,33 @@ public function peek($limit = 1)
     /**
      * @inheritdoc
      */
-    public function count()
+    public function countReady(): int
     {
         $this->checkClientConnection();
         return $this->client->lLen("queue:{$this->name}:messages");
     }
 
+    /**
+     * @inheritdoc
+     */
+    public function countReserved(): int
+    {
+        $this->checkClientConnection();
+        return $this->client->lLen("queue:{$this->name}:processing");
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function countFailed(): int
+    {
+        $this->checkClientConnection();
+        return $this->client->lLen("queue:{$this->name}:failed");
+    }
+
     /**
      * @return void
+     * @throws JobQueueException
      */
     public function setUp()
     {
@@ -279,4 +298,4 @@ protected function connectClient()
         }
         return $connected;
     }
-}
+}
diff --git a/composer.json b/composer.json
@@ -5,7 +5,7 @@
     "license": "MIT",
     "require": {
         "ext-redis": "*",
-        "flowpack/jobqueue-common": "^2.0"
+        "flowpack/jobqueue-common": "^3.0 || dev-master"
     },
     "autoload": {
         "psr-4": {