PDO based queues: Fix consume looping attempting to processs queue it…

…ems we say waiting but no longer exist in the queue
AllenJB · Dec 18, 2020 · 8d9d664 · 8d9d664
1 parent 2c0d109
commit 8d9d664
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/Pdo/Queue.php b/src/Pdo/Queue.php
@@ -109,6 +109,8 @@ public function consume(callable $callback, float $timeoutSecs): void
                     ->withCorrelationId($row["correlation_id"]);
 
                 $callback($this, $message);
+            } else {
+                $waitingReplies = 0;
             }
 
             if (microtime(true) > $tsLimit) {

diff --git a/src/Pdo/ReplyQueue.php b/src/Pdo/ReplyQueue.php
@@ -153,6 +153,8 @@ public function consume(callable $callback, float $timeoutSecs): void
                 if (($this->expectedResponseCount !== null) && ($this->responses >= $this->expectedResponseCount)) {
                     break;
                 }
+            } else {
+                $waitingReplies = 0;
             }
 
             if (microtime(true) > $tsLimit) {