Default to 0 messages

abnegate · abnegate · commit a98d5ecf21ba · 2025-07-01T12:50:34.000-04:00
diff --git 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;
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -154,6 +154,9 @@ public function retry(Queue $queue, ?int $limit = null): void`
`154`	`154`	`// This is a no-op for AMQP`
`155`	`155`	`}`
`156`	`156`
	`157`	`+ /**`
	`158`	`+ * @throws \Exception`
	`159`	`+ */`
`157`	`160`	`public function getQueueSize(Queue $queue, bool $failedJobs = false): int`
`158`	`161`	`{`
`159`	`162`	`$queueName = $queue->name;`
`@@ -174,7 +177,8 @@ public function getQueueSize(Queue $queue, bool $failedJobs = false): int`
`174`	`177`	`}`
`175`	`178`
`176`	`179`	`$data = $response->json();`
`177`		`- return $data['messages'];`
	`180`	`+`
	`181`	`+ return $data['messages'] ?? 0;`
`178`	`182`	`}`
`179`	`183`
`180`	`184`	`/**`