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

Don't spam the terminal. No beuno.

Browse source
This commit is contained in:
Greyscale 2020-12-05 01:45:02 +01:00
parent b1bba4cbfb
commit 1049d2dbd7
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/Workers/AbstractQueueWorker.php
View file

@ -19,6 +19,8 @@ abstract class AbstractQueueWorker extends AbstractWorker
protected bool $showRemainingQueueLength = true;
protected int $lastLength = -1;
public function __construct(
QueueService $queueService,
Logger $logger,
@ -95,12 +97,13 @@ abstract class AbstractQueueWorker extends AbstractWorker
public function iterate(): bool
{
$queueLength = $this->queueService->getQueueLength($this->inputQueue);
if ($this->showRemainingQueueLength) {
if ($this->showRemainingQueueLength && $queueLength != $this->lastLength) {
$this->logger->debug(sprintf(
'Queue %s Length: %d',
$this->inputQueue,
$queueLength
));
$this->lastLength = $queueLength;
}
if (isset($this->cliArguments['stop-on-zero']) && true === $this->cliArguments['stop-on-zero'] && 0 == $queueLength) {