MessageApp\Listener\DomainMessageListener

Complexity

Total Complexity

4

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	7	1
A	getContext()	0	7	2

<?php

namespace MessageApp\Listener;

use Broadway\Domain\DomainMessage;
use Broadway\EventHandling\EventListenerInterface;
use Broadway\Tools\Metadata\Context\ContextEnricher;

class DomainMessageListener implements EventListenerInterface
{
    /**
     * @var MessageEventHandler
     */
    private $handler;

    /**
     * Constructor
     *
     * @param MessageEventHandler $handler
     */
    public function __construct(MessageEventHandler $handler)
    {
        $this->handler = $handler;
    }

    /**
     * Handle an event.
     *
     * @param DomainMessage $message
     *
     * @return void
     */
    public function handle(DomainMessage $message)
    {
        $event = $message->getPayload();
        $context = static::getContext($message);

Since getContext() is declared private, calling it with static will lead to errors in possible sub-classes. You can either use self, or increase the visibility of getContext() to at least protected.

        $this->handler->handle($event, $context);
    }

    /**
     * @param  DomainMessage $message
     *
     * @return mixed
     */
    private static function getContext(DomainMessage $message)
    {
        $metadataArray = $message->getMetadata()->serialize();
        $context = isset($metadataArray[ContextEnricher::CONTEXT]) ? $metadataArray[ContextEnricher::CONTEXT] : null;

        return $context;
    }
}