Happyr\Mq2phpBundle\Consumer\ExtendableEnvelopeConsumer

Complexity

Total Complexity

2

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

50%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	consume()	0	11	1

<?php

namespace Happyr\Mq2phpBundle\Consumer;

use Happyr\Mq2phpBundle\Event\PreHandleMessage;
use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopeSerializer;
use SimpleBus\Message\Bus\MessageBus;
use SimpleBus\Asynchronous\Consumer\SerializedEnvelopeConsumer as SimpleBusSerializedEnvelopeConsumer;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Use this consumer to easily implement an asynchronous message consumer.
 */
class ExtendableEnvelopeConsumer implements SimpleBusSerializedEnvelopeConsumer
{
    /**
     * @var MessageInEnvelopeSerializer
     */
    private $messageInEnvelopeSerializer;

    /**
     * @var MessageBus
     */
    private $messageBus;

    /**
     * @var EventDispatcherInterface
     */
    private $dispathcer;

    /**
     * @param MessageInEnvelopeSerializer $messageInEnvelopeSerializer
     * @param MessageBus                 $messageBus
     * @param EventDispatcherInterface   $dispathcer
     */
    public function __construct(
        MessageInEnvelopeSerializer $messageInEnvelopeSerializer,
        MessageBus $messageBus,
        EventDispatcherInterface $dispathcer
    ) {
        $this->messageInEnvelopeSerializer = $messageInEnvelopeSerializer;
        $this->messageBus = $messageBus;
        $this->dispathcer = $dispathcer;
    }

    /**
     * @param string $serializedEnvelope
     */
    public function consume($serializedEnvelope)
    {
        // Unserialize
        $envelope = $this->messageInEnvelopeSerializer->unwrapAndDeserialize($serializedEnvelope);

        // Tell the world
        $this->dispathcer->dispatch(PreHandleMessage::NAME, new PreHandleMessage($envelope));

        // Handle the message
        $this->messageBus->handle($envelope->message());
    }
}