Benzine/Core
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Allow surpressing of queue length reports.

Browse source
This commit is contained in:
Greyscale 2020-11-23 17:04:02 +01:00
parent 2ef842024c
commit afe7d1f949
No known key found for this signature in database
GPG key ID: C6178C19949CFFE3
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/Workers/AbstractQueueWorker.php
View file

@ -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!');