Transactional   A
last analyzed

Complexity

Total Complexity 2

Size/Duplication

Total Lines 18
Duplicated Lines 0 %

Importance

Changes 0
Metric Value
wmc 2
eloc 6
c 0
b 0
f 0
dl 0
loc 18
rs 10

2 Methods

Rating   Name   Duplication   Size   Complexity  
A __construct() 0 3 1
A dispatch() 0 4 1
1
<?php
2
declare(strict_types=1);
3
4
namespace OniBus\Buses;
5
6
use OniBus\Chain;
7
use OniBus\ChainTrait;
8
use OniBus\Message;
9
10
class Transactional implements Chain
11
{
12
    use ChainTrait;
13
14
    /**
15
     * @var TransactionalSession
16
     */
17
    protected $session;
18
19
    public function __construct(TransactionalSession $session)
20
    {
21
        $this->session = $session;
22
    }
23
24
    public function dispatch(Message $message)
25
    {
26
        return $this->session->executeAtomically(function () use ($message) {
27
            $this->next($message);
28
        });
29
    }
30
}
31