From a98d5ecf21ba8f2b72fd52911e3701da217abb04 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Tue, 1 Jul 2025 12:50:34 -0400 Subject: [PATCH] Default to 0 messages --- src/Queue/Broker/AMQP.php | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/Queue/Broker/AMQP.php b/src/Queue/Broker/AMQP.php index 65a1624..f547038 100644 --- a/src/Queue/Broker/AMQP.php +++ b/src/Queue/Broker/AMQP.php @@ -154,6 +154,9 @@ public function retry(Queue $queue, ?int $limit = null): void // This is a no-op for AMQP } + /** + * @throws \Exception + */ public function getQueueSize(Queue $queue, bool $failedJobs = false): int { $queueName = $queue->name; @@ -174,7 +177,8 @@ public function getQueueSize(Queue $queue, bool $failedJobs = false): int } $data = $response->json(); - return $data['messages']; + + return $data['messages'] ?? 0; } /**