Genkgo\Mail\Queue\LimitQueueProcessor::process()

Complexity

Conditions	7
Paths	9

Size

Total Lines	26
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	14
CRAP Score	7

Importance

Changes

0

<?php
    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;
    }
}