Genkgo\Mail\Queue\LimitQueueProcessor

Complexity

Total Complexity

8

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
C	process()	0	26	7

<?php

namespace Genkgo\Mail\Queue;

use Genkgo\Mail\Exception\AbstractProtocolException;
use Genkgo\Mail\Exception\EmptyQueueException;
use Genkgo\Mail\TransportInterface;

/**
 * Class LimitQueueProcessor
 * @package Genkgo\Mail\Queue
 */
final class LimitQueueProcessor implements QueueProcessorInterface
{
    /**
     * @var TransportInterface
     */
    private $transport;
    /**
     * @var iterable|QueueInterface[]
     */
    private $queue;
    /**
     * @var int
     */
    private $limit;

    /**
     * @param TransportInterface $transport
     * @param QueueInterface[] $queue
     */
    public function __construct(TransportInterface $transport, iterable $queue, int $limit)
    {
        $this->transport = $transport;
        $this->queue = $queue;
        $this->limit = $limit;
    }

    /**
     * {@inheritdoc}
     */
    public function process(): int
    {
        $count = 0;
        foreach ($this->queue as $queue) {
            try {
                while ($message = $queue->fetch()) {
                    if ($this->limit > 0 && $this->limit <= $count) {
                        $queue->store($message);

                        return $count;
                    }
                    try {
                        $this->transport->send($message);
                    } catch (AbstractProtocolException $e) {
                        $queue->store($message);

                        return $count;
                    }
                    ++$count;
                }
            } catch (EmptyQueueException $e) {

Consider adding a comment why this CATCH block is empty.

            }
        }

        return $count;
    }
}