Umbrellio\TableSync\Integration\Laravel\Jobs\ReceiveMessage

Complexity

Total Complexity

2

Size/Duplication

Total Lines	16
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	handle()	0	3	1

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Integration\Laravel\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Support\Facades\Config;
use Umbrellio\LaravelHeavyJobs\Jobs\ShouldStorePayload;
use Umbrellio\TableSync\Integration\Laravel\Receive\Receiver;
use Umbrellio\TableSync\Messages\ReceivedMessage;

final class ReceiveMessage implements ShouldQueue, ShouldStorePayload
{
    use HeavyJobsEnabledTrait;
    use Queueable;

    private $message;

    public function __construct(ReceivedMessage $message)
    {
        $this->queue = Config::get('table_sync.receive_job_queue', '');
        $this->message = $message;
    }

    public function handle(Receiver $receiver): void
    {
        $receiver->receive($this->message);
    }
}