Werkspot\MessageBus\MessageQueue\WerkspotMessageQueue\MessageQueueService

Complexity

Total Complexity

2

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

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

<?php

namespace Werkspot\MessageBus\MessageQueue\WerkspotMessageQueue;

use Werkspot\MessageBus\MessageQueue\AsynchronousMessageInterface;
use Werkspot\MessageBus\MessageQueue\MessageQueueServiceInterface;
use Werkspot\MessageQueue\MessageQueueServiceInterface as WerkspotMessageQueueServiceInterface;

final class MessageQueueService implements MessageQueueServiceInterface
{
    /**
     * @var WerkspotMessageQueueServiceInterface
     */
    private $werkspotMessageQueueService;

    public function __construct(WerkspotMessageQueueServiceInterface $werkspotMessageQueueService)
    {
        $this->werkspotMessageQueueService = $werkspotMessageQueueService;
    }

    public function enqueueMessage(AsynchronousMessageInterface $message): void
    {
        $this->werkspotMessageQueueService->enqueueMessage(
            $message->getPayload(),
            $message->getDestination(),
            $message->getDeliverAt(),
            $message->getPriority()->toInt(),
            $message->getMetadata()
        );
    }
}