OldSound\RabbitMqBundle\ReceiverExecutor\SingleReceiverExecutor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	10	3
A	support()	0	3	1

<?php

namespace OldSound\RabbitMqBundle\ReceiverExecutor;

use OldSound\RabbitMqBundle\Declarations\ConsumeOptions;
use OldSound\RabbitMqBundle\Receiver\ReceiverInterface;

class SingleReceiverExecutor implements ReceiverExecutorInterface
{
    /**
     * @param ReceiverInterface $receiver
     */
    public function execute($messages, $receiver): array
    {
        if (!$this->support($receiver)) {
            throw new \InvalidArgumentException('todo');
        }
        if (count($messages) !== 1) {
            throw new \InvalidArgumentException('todo');
        }

        return [$receiver->execute($messages[0])];
    }

    public function support($receiver): bool
    {
        return $receiver instanceof ReceiverInterface;
    }
}