Umbrellio\TableSync\Integration\Laravel\Publishers\QueuePublisher

Complexity

Total Complexity

2

Size/Duplication

Total Lines	14
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	publish()	0	3	1

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Integration\Laravel\Publishers;

use Illuminate\Contracts\Bus\Dispatcher;
use Umbrellio\TableSync\Integration\Laravel\Jobs\PublishJob;
use Umbrellio\TableSync\Messages\PublishMessage;
use Umbrellio\TableSync\Publisher;

final class QueuePublisher implements Publisher
{
    private $publisher;
    private $dispatcher;

    public function __construct(Publisher $publisher, Dispatcher $dispatcher)
    {
        $this->publisher = $publisher;
        $this->dispatcher = $dispatcher;
    }

    public function publish(PublishMessage $message): void
    {
        $this->dispatcher->dispatch(new PublishJob(get_class($this->publisher), $message));
    }
}