PDO based queues: Fix excessively low poll interval, and make it conf…

…igurable (fix missed method signature)
AllenJB · Oct 20, 2021 · b1ecdb7 · b1ecdb7
1 parent f65432c
commit b1ecdb7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/QueueInterface.php b/src/QueueInterface.php
@@ -14,7 +14,7 @@ public function publish(QueueMessage $message, \DateTimeImmutable $delayTo = nul
     /**
      * @param callable $callback Callback with parameters: QueueInterface $this, QueueMessage
      */
-    public function consume(callable $callback, float $timeoutSecs, float $pollIntervalSecs): void;
+    public function consume(callable $callback, float $timeoutSecs, ?float $pollIntervalSecs): void;
 
 
     public function ack(QueueMessage $message): void;

diff --git a/src/Rabbit/RPCQueue.php b/src/Rabbit/RPCQueue.php
@@ -34,7 +34,7 @@ public function publish(QueueMessage $message): PromiseInterface
     }
 
 
-    public function consume(callable $callback, float $timeoutSecs): void
+    public function consume(callable $callback, float $timeoutSecs, ?float $pollIntervalSecs = null): void
     {
         $this->replyQueue->consume($callback, $timeoutSecs);
     }

diff --git a/src/Rabbit/ReplyQueue.php b/src/Rabbit/ReplyQueue.php
@@ -80,7 +80,7 @@ public function publish(QueueMessage $message): PromiseInterface
     }
 
 
-    public function consume(callable $callback, float $timeoutSecs): void
+    public function consume(callable $callback, float $timeoutSecs, ?float $pollIntervalSecs = null): void
     {
         $this->channel->consume(
             function (BunnyMessage $message, Channel $channel, Client $client) use ($callback) {