TransactionalEventBus::publish() - Code Metrics - remi-san/broadway-tools - Measure and Improve Code Quality continuously with Scrutinizer

TransactionalEventBus::publish() A
last analyzed 2019-07-11 08:16 UTC

↳ Parent: TransactionalEventBus

Complexity

Conditions	2
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	11
ccs	8
cts	8
cp	1
rs	9.9
c	0
b	0
f	0
cc	2
nc	3
nop	1
crap	2

<?php

namespace Broadway\Tools\Event;

use Broadway\Domain\DomainEventStream;
use Broadway\EventHandling\EventBus;
use Broadway\EventHandling\EventListener;
use RemiSan\TransactionManager\TransactionManager;

class TransactionalEventBus implements EventBus
{
    /**
     * @var EventBus
     */
    private $eventBus;

    /**
     * @var TransactionManager
     */
    private $transactionManager;

    /**
     * @param EventBus           $eventBus
     * @param TransactionManager $transactionManager
     */
    public function __construct(EventBus $eventBus, TransactionManager $transactionManager)
    {
        $this->eventBus = $eventBus;
        $this->transactionManager = $transactionManager;
    }

    /**
     * Subscribes the event listener to the event bus.
     *
     * @param EventListener $eventListener
     */
    public function subscribe(EventListener $eventListener)
    {
        $this->eventBus->subscribe($eventListener);
    }

    /**
     * Publishes the events from the domain event stream to the listeners.
     *
     * @param DomainEventStream $domainMessages
     * @throws \Exception
     */
    public function publish(DomainEventStream $domainMessages)
    {
        $this->transactionManager->beginTransaction();
        try {
            $this->eventBus->publish($domainMessages);
            $this->transactionManager->commit();
        } catch (\Exception $e) {
            $this->transactionManager->rollback();
            throw $e;
        }
    }
}


1		<?php
2
3		namespace Broadway\Tools\Event;
4
5		use Broadway\Domain\DomainEventStream;
6		use Broadway\EventHandling\EventBus;
7		use Broadway\EventHandling\EventListener;
8		use RemiSan\TransactionManager\TransactionManager;
9
10		class TransactionalEventBus implements EventBus
11		{
12		/**
13		* @var EventBus
14		*/
15		private $eventBus;
16
17		/**
18		* @var TransactionManager
19		*/
20		private $transactionManager;
21
22		/**
23		* @param EventBus $eventBus
24		* @param TransactionManager $transactionManager
25		*/
26	9	public function __construct(EventBus $eventBus, TransactionManager $transactionManager)
27		{
28	9	$this->eventBus = $eventBus;
29	9	$this->transactionManager = $transactionManager;
30	9	}
31
32		/**
33		* Subscribes the event listener to the event bus.
34		*
35		* @param EventListener $eventListener
36		*/
37	3	public function subscribe(EventListener $eventListener)
38		{
39	3	$this->eventBus->subscribe($eventListener);
40	3	}
41
42		/**
43		* Publishes the events from the domain event stream to the listeners.
44		*
45		* @param DomainEventStream $domainMessages
46		* @throws \Exception
47		*/
48	6	public function publish(DomainEventStream $domainMessages)
49		{
50	6	$this->transactionManager->beginTransaction();
51		try {
52	6	$this->eventBus->publish($domainMessages);
53	3	$this->transactionManager->commit();
54	5	} catch (\Exception $e) {
55	3	$this->transactionManager->rollback();
56	3	throw $e;
57		}
58	3	}
59		}
60

remi-san / broadway-tools

GitHub Access Token became invalid

TransactionalEventBus::publish() A last analyzed 2019-07-11 08:16 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

TransactionalEventBus::publish() A
last analyzed 2019-07-11 08:16 UTC