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

Complexity

Conditions	5
Paths	8

Size

Total Lines

23

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	5

Importance

Changes

0

<?php
    public function process(): int
    {
        $count = 0;
        foreach ($this->queue as $queue) {
            try {
                while ($message = $queue->fetch()) {
                    try {
                        $this->transport->send($message);
                    } catch (AbstractProtocolException $e) {
                        $queue->store($message);

                        // do not continue transporting messages
                        // apparently our transport is not ready to receive messages yet
                        return $count;
                    }
                    ++$count;
                }
            } catch (EmptyQueueException $e) {
            }
        }

        return $count;
    }
}