From afe7d1f949cb4f701229d4c86d4e367558dd5e95 Mon Sep 17 00:00:00 2001 From: Matthew Baggett Date: Mon, 23 Nov 2020 17:04:02 +0100 Subject: [PATCH] Allow surpressing of queue length reports. --- src/Workers/AbstractQueueWorker.php | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/src/Workers/AbstractQueueWorker.php b/src/Workers/AbstractQueueWorker.php index 5299e54..c581a28 100644 --- a/src/Workers/AbstractQueueWorker.php +++ b/src/Workers/AbstractQueueWorker.php @@ -17,6 +17,8 @@ abstract class AbstractQueueWorker extends AbstractWorker protected ?array $resultItems; + protected bool $showRemainingQueueLength = true; + public function __construct( QueueService $queueService, Logger $logger, @@ -93,11 +95,13 @@ abstract class AbstractQueueWorker extends AbstractWorker public function iterate(): bool { $queueLength = $this->queueService->getQueueLength($this->inputQueue); - $this->logger->debug(sprintf( - 'Queue %s Length: %d', - $this->inputQueue, - $queueLength - )); + if($this->showRemainingQueueLength) { + $this->logger->debug(sprintf( + 'Queue %s Length: %d', + $this->inputQueue, + $queueLength + )); + } if (isset($this->cliArguments['stop-on-zero']) && true === $this->cliArguments['stop-on-zero'] && 0 == $queueLength) { $this->logger->warning('--stop-on-zero is set, and the queue length is zero! Stopping!');