Damax\Common\Bridge\Enqueue\Consumption\Extension\EventPublisherExtension

Complexity

Total Complexity

3

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	onInterrupted()	0	3	1
A	onPostReceived()	0	3	1

<?php

declare(strict_types=1);

namespace Damax\Common\Bridge\Enqueue\Consumption\Extension;

use Damax\Common\Domain\EventPublisher\EventPublisher;
use Enqueue\Consumption\Context;
use Enqueue\Consumption\EmptyExtensionTrait;
use Enqueue\Consumption\ExtensionInterface;

final class EventPublisherExtension implements ExtensionInterface
{
    use EmptyExtensionTrait;

    private $eventPublisher;

    public function __construct(EventPublisher $eventPublisher)
    {
        $this->eventPublisher = $eventPublisher;
    }

    public function onPostReceived(Context $context): void
    {
        $this->eventPublisher->publish();
    }

    public function onInterrupted(Context $context): void
    {
        $this->eventPublisher->publish();
    }
}