Wandu\Q\Commands\FlushCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	1	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	execute()	0	20	5

<?php
namespace Wandu\Q\Commands;

use Psr\Log\LoggerInterface;
use Wandu\Console\Command;
use Wandu\Q\Queue;

class FlushCommand extends Command
{
    /** @var \Wandu\Q\Queue */
    protected $queue;

    /** @var \Psr\Log\LoggerInterface */
    protected $logger;

    public function __construct(Queue $queue, LoggerInterface $logger)
    {
        $this->queue = $queue;
        $this->logger = $logger;
    }

    function execute()

It is generally recommended to explicitly declare the visibility for methods.

    {
        try {
            while (1) {
                $job = $this->queue->dequeue();
                if (!isset($job)) {
                    return;
                }
                $payload = $job->read();
                $this->output->writeln("  Flush, " . print_r($payload, true));
                $job->delete();
            }
        } catch (\Exception $e) {
            $this->logger->alert($e);
            throw $e;
        } catch (\Throwable $e) {
            $this->logger->alert($e);
            throw $e;
        }
    }
}