OldSound\RabbitMqBundle\ReceiverExecutor\BatchReceiverExecutor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

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

<?php


namespace OldSound\RabbitMqBundle\ReceiverExecutor;

use OldSound\RabbitMqBundle\Declarations\BatchConsumeOptions;
use OldSound\RabbitMqBundle\Receiver\BatchReceiverInterface;

class BatchReceiverExecutor implements ReceiverExecutorInterface
{
    /**
     * @param BatchReceiverInterface $receiver
     */
    public function execute($messages, $receiver): array
    {
        if (!$this->support($receiver)) {
            throw new \InvalidArgumentException('TOOD');
        }
        $flags = $receiver->batchExecute($messages);

        if (!is_array($flags)) { // flat flag for each delivery tag
            $flag = $flags;
            $flags = [];
            foreach ($messages as $message) {
                $flags[$message->getDeliveryTag()] = $flag;
            }
        } else if (count($flags) !== count($messages)) {
            throw new AMQPRuntimeException(// TODO

The type OldSound\RabbitMqBundle\ReceiverExecutor\AMQPRuntimeException was not found. Maybe you did not declare it correctly or list all dependencies?

                'Method batchExecute() should return an array with elements equal with the number of messages processed'
            );
        }

        return $flags;
    }

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