Merge pull request #50 from utopia-php/fix-queue-size

Default to 0 messages

Author: abnegate

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;
     }
 
     /**