From 5cf96be1bb165090685e8159ea0a7348121839f4 Mon Sep 17 00:00:00 2001
From: butschster <butschster@gmail.com>
Date: Wed, 19 Jan 2022 12:33:26 +0300
Subject: [PATCH] Fixes problem with queue "is paused" state checking

---
 src/Queue.php | 28 ++++++++++++++++------------
 1 file changed, 16 insertions(+), 12 deletions(-)

diff --git a/src/Queue.php b/src/Queue.php
index a31b7f3..7d97b35 100644
--- a/src/Queue.php
+++ b/src/Queue.php
@@ -203,6 +203,20 @@ public function resume(): void
      * {@inheritDoc}
      */
     public function isPaused(): bool
+    {
+        $stat = $this->getPipelineStat();
+
+        return $stat !== null && ! $stat->getReady();
+    }
+
+    private function createRPCConnection(): RPCInterface
+    {
+        $env = Environment::fromGlobals();
+
+        return RPC::create($env->getRPCAddress());
+    }
+
+    public function getPipelineStat(): ?Stat
     {
         try {
             /** @var Stats $stats */
@@ -214,20 +228,10 @@ public function isPaused(): bool
         /** @var Stat $stat */
         foreach ($stats->getStats() as $stat) {
             if ($stat->getPipeline() === $this->name) {
-                return $stat->getActive() !== 0;
+                return $stat;
             }
         }
 
-        return false;
-    }
-
-    /**
-     * @return RPCInterface
-     */
-    private function createRPCConnection(): RPCInterface
-    {
-        $env = Environment::fromGlobals();
-
-        return RPC::create($env->getRPCAddress());
+        return null;
     }
 }