Chocofamily\LaravelEventSauce\MessageDispatcher

Complexity

Total Complexity

4

Size/Duplication

Total Lines	22
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	dispatch()	0	7	3
A	__construct()	0	5	1

<?php

namespace Chocofamily\LaravelEventSauce;

use EventSauce\EventSourcing\Message;
use EventSauce\EventSourcing\MessageDispatcher as EventSauceMessageDispatcher;
use Illuminate\Contracts\Queue\ShouldQueue;

final class MessageDispatcher implements EventSauceMessageDispatcher
{
    /** @var array */
    private $consumers;

    /** @var string */
    private $handlerClass;

    public function __construct(string $handlerClass, array $consumers)
    {
        $this->handlerClass = $handlerClass;

        $this->consumers = $consumers;
    }

    public function dispatch(Message ...$messages)
    {
        foreach ($this->consumers as $consumer) {
            if (is_a($consumer, ShouldQueue::class, true)) {
                dispatch(new $this->handlerClass($consumer, ...$messages));
            } else {
                dispatch_now(new $this->handlerClass($consumer, ...$messages));
            }
        }
    }
}