OldSound\RabbitMqBundle\ReceiverExecutor\BatchReceiverExecutor::execute()

Complexity

Conditions	5
Paths	4

Size

Total Lines	20
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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