Saxulum\MessageQueue\AbstractMessageReceive

Complexity

Total Complexity

2

Size/Duplication

Total Lines	17
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	receiveAll()	0	9	2

<?php

namespace Saxulum\MessageQueue;

abstract class AbstractMessageReceive implements MessageReceiveInterface
{
    /**
     * @return array
     *
     * @throws MessageReceiveException
     */
    public function receiveAll(): array
    {
        $messages = [];
        while (null !== $message = $this->receive()) {
            $messages[] = $message;
        }

        return $messages;
    }
}