Werkspot\MessageQueue\MessageQueueService

Complexity

Total Complexity

2

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	enqueueMessage()	0	14	1

<?php

namespace Werkspot\MessageQueue;

use DateTimeImmutable;
use Werkspot\MessageQueue\Message\Message;
use Werkspot\MessageQueue\ScheduledQueue\ScheduledQueueServiceInterface;

final class MessageQueueService implements MessageQueueServiceInterface
{
    /**
     * @var ScheduledQueueServiceInterface
     */
    private $scheduledMessageQueueService;

    public function __construct(ScheduledQueueServiceInterface $scheduledMessageQueueService)
    {
        $this->scheduledMessageQueueService = $scheduledMessageQueueService;
    }

    public function enqueueMessage(
        $payload,
        string $destination,
        DateTimeImmutable $deliverAt,
        int $priority,
        array $metadata
    ): void {
        $this->scheduledMessageQueueService->scheduleMessage(
            new Message(
                $payload,
                $destination,
                $deliverAt,
                $priority,
                $metadata
            )
        );
    }
}