Werkspot\MessageBus\MessageDispatcher

Complexity

Total Complexity

3

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	dispatchQueuedMessage()	0	8	1
A	dispatchSynchronousMessage()	0	6	1
A	__construct()	0	3	1

<?php

namespace Werkspot\MessageBus;

use DateTimeImmutable;
use Werkspot\MessageBus\Bus\Bus;
use Werkspot\MessageBus\Bus\BusInterface;
use Werkspot\MessageBus\Message\AsynchronousMessage;
use Werkspot\MessageBus\Message\Message;
use Werkspot\MessageBus\MessageQueue\Priority;

final class MessageDispatcher implements MessageDispatcherInterface
{
    /**
     * @var Bus
     */
    private $bus;

    public function __construct(BusInterface $bus)
    {
        $this->bus = $bus;

$bus is of type Werkspot\MessageBus\Bus\BusInterface, but the property $bus was declared to be of type Werkspot\MessageBus\Bus\Bus. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

    }

    public function dispatchSynchronousMessage(
        $payload,
        string $destination,
        array $metadataCollection = []
    ): void {
        $this->bus->deliver(new Message($payload, $destination, $metadataCollection));
    }

    public function dispatchQueuedMessage(
        $payload,
        string $destination,
        array $metadataCollection = [],
        DateTimeImmutable $deliverAt = null,
        Priority $priority = null
    ): void {
        $this->bus->deliver(new AsynchronousMessage($payload, $destination, $metadataCollection, $deliverAt, $priority));
    }
}