diff --git a/src/Queue/RabbitMQQueue.php b/src/Queue/RabbitMQQueue.php index 957620ef..2c4d9afe 100644 --- a/src/Queue/RabbitMQQueue.php +++ b/src/Queue/RabbitMQQueue.php @@ -73,6 +73,17 @@ public function __construct(QueueConfig $config) $this->dispatchAfterCommit = $config->isDispatchAfterCommit(); } + /** + * Get the number of queue jobs that are ready to process. + * + * @param string|null $queue + * @return int + */ + public function readyNow($queue = null): int + { + return $this->size($queue); + } + /** * {@inheritdoc} *