EventPublisherExtension::__construct()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 1
eloc 1
c 1
b 0
f 0
nc 1
nop 1
dl 0
loc 3
rs 10
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Damax\Common\Bridge\Enqueue\Consumption\Extension;
6
7
use Damax\Common\Domain\EventPublisher\EventPublisher;
8
use Enqueue\Consumption\Context;
9
use Enqueue\Consumption\EmptyExtensionTrait;
10
use Enqueue\Consumption\ExtensionInterface;
11
12
final class EventPublisherExtension implements ExtensionInterface
13
{
14
    use EmptyExtensionTrait;
15
16
    private $eventPublisher;
17
18
    public function __construct(EventPublisher $eventPublisher)
19
    {
20
        $this->eventPublisher = $eventPublisher;
21
    }
22
23
    public function onPostReceived(Context $context): void
24
    {
25
        $this->eventPublisher->publish();
26
    }
27
28
    public function onInterrupted(Context $context): void
29
    {
30
        $this->eventPublisher->publish();
31
    }
32
}
33