MessageQueueService::enqueueMessage()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 14
Code Lines 7

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 8
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 14
ccs 8
cts 8
cp 1
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 7
nc 1
nop 5
crap 1
1
<?php
2
3
namespace Werkspot\MessageQueue;
4
5
use DateTimeImmutable;
6
use Werkspot\MessageQueue\Message\Message;
7
use Werkspot\MessageQueue\ScheduledQueue\ScheduledQueueServiceInterface;
8
9
final class MessageQueueService implements MessageQueueServiceInterface
10
{
11
    /**
12
     * @var ScheduledQueueServiceInterface
13
     */
14
    private $scheduledMessageQueueService;
15
16 2
    public function __construct(ScheduledQueueServiceInterface $scheduledMessageQueueService)
17
    {
18 2
        $this->scheduledMessageQueueService = $scheduledMessageQueueService;
19 2
    }
20
21 2
    public function enqueueMessage(
22
        $payload,
23
        string $destination,
24
        DateTimeImmutable $deliverAt,
25
        int $priority,
26
        array $metadata
27
    ): void {
28 2
        $this->scheduledMessageQueueService->scheduleMessage(
29 2
            new Message(
30 2
                $payload,
31 2
                $destination,
32 2
                $deliverAt,
33 2
                $priority,
34 2
                $metadata
35
            )
36
        );
37 2
    }
38
}
39