Werkspot\MessageQueue\DeliveryQueueToHandlerWorker

Complexity

Total Complexity

2

Size/Duplication

Total Lines	23
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	startConsuming()	0	3	1

<?php

namespace Werkspot\MessageQueue;

use Werkspot\MessageQueue\DeliveryQueue\ConsumerInterface;

final class DeliveryQueueToHandlerWorker implements DeliveryQueueToHandlerWorkerInterface
{
    /**
     * @var ConsumerInterface
     */
    private $deliveryQueueMessageConsumer;

    /**
     * @var string
     */
    private $deliveryQueueName;

    public function __construct(
        ConsumerInterface $deliveryQueueMessageConsumer,
        string $deliveryQueueName
    ) {
        $this->deliveryQueueMessageConsumer = $deliveryQueueMessageConsumer;
        $this->deliveryQueueName = $deliveryQueueName;
    }

    public function startConsuming(int $maxExecutionTimeInSeconds): void
    {
        $this->deliveryQueueMessageConsumer->startConsuming($this->deliveryQueueName, $maxExecutionTimeInSeconds);
    }
}