OldSound\RabbitMqBundle\ReceiverExecutor\ReceiverExecutorDecorator

Complexity

Total Complexity

10

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	34	5
A	support()	0	3	1
A	__construct()	0	4	1
A	createLoggerExtraContext()	0	12	3

<?php

namespace OldSound\RabbitMqBundle\ReceiverExecutor;

use OldSound\RabbitMqBundle\Event\AfterProcessingMessagesEvent;
use OldSound\RabbitMqBundle\Event\BeforeProcessingMessagesEvent;
use OldSound\RabbitMqBundle\Logger\ExtraContextLogger;
use OldSound\RabbitMqBundle\RabbitMq\Consuming;

class ReceiverExecutorDecorator implements ReceiverExecutorInterface
{
    /** @var Consuming */
    private $consuming;

    /** @var LoggerInterface */

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

    private $logger;

    public function __construct(Consuming $consuming, LoggerInterface $logger)
    {
        $this->consuming = $consuming;
        $this->logger = $logger;
    }

    private function createLoggerExtraContext(array $messages)
    {
        $amqpContext = ['queue' => $this->consuming->options->queue];
        if ($this->consuming->executeReceiverStrategy->canPrecessMultiMessages()) {
            $amqpContext['messages'] = $messages;
        } else {
            if (count($messages) > 1) {
                // TODO
            }
            $amqpContext['message'] = $messages[0];
        }
        return $amqpContext;
    }

    public function execute(array $messages, $receiver): array
    {
        $logger = new ExtraContextLogger($this->logger, ['amqp' => $this->createLoggerExtraContext($messages)]);

        $event = new BeforeProcessingMessagesEvent($messages, $this->consuming->options);
        $this->dispatchEvent(BeforeProcessingMessagesEvent::NAME, $event);

The method dispatchEvent() does not exist on OldSound\RabbitMqBundle\ReceiverExecutor\ReceiverExecutorDecorator.

        if ($event->isStoppingConsumer()) {
            throw new StopConsumerException();

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

        }

        try {
            $flags = $this->consuming->receiverExecutor->execute($messages, $receiver);
        } catch (Exception\StopConsumerException $e) {

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

            $logger->info('Consumer requested stop', [
                'exception' => $e
            ]);

            throw $e;
        } catch (\Throwable $e) {
            $logger->error('Throw exception while process messages', [
                'exception' => $e
            ]);
            throw $e;
        }


        $logger->info('Queue messages processed'); // TODO add flag code
        $event = new AfterProcessingMessagesEvent($this, $messages); // TODO add flag code

$this of type OldSound\RabbitMqBundle\ReceiverExecutor\ReceiverExecutorDecorator is incompatible with the type OldSound\RabbitMqBundle\RabbitMq\Consumer expected by parameter $consumer of OldSound\RabbitMqBundle\Event\AfterProcessingMessagesEvent::__construct().

        $this->dispatchEvent(AfterProcessingMessagesEvent::NAME, $event);
        if ($event->isStoppingConsumer()) {
            throw new StopConsumerException();
        }

        return $flags;
    }

    public function support($receiver): bool
    {
        return $this->consuming->receiverExecutor->support($receiver);
    }
}