TransactionalEventBus::__construct() - Code Metrics - Inspection of "added transactional event bus and tests" - remi-san/broadway-tools - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 9447a8...2ae261 )

by Rémi

created 2016-06-02 20:03 UTC

TransactionalEventBus::__construct() A

↳ Parent: TransactionalEventBus

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	5
ccs	4
cts	4
cp	1
rs	9.4285
cc	1
eloc	3
nc	1
nop	2
crap	1

<?php

namespace Broadway\Tools\Event;

use Broadway\Domain\DomainEventStreamInterface;
use Broadway\EventHandling\EventBusInterface;
use Broadway\EventHandling\EventListenerInterface;
use RemiSan\TransactionManager\TransactionManager;

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

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

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

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

    /**
     * Publishes the events from the domain event stream to the listeners.
     *
     * @param DomainEventStreamInterface $domainMessages
     * @throws \Exception
     */
    public function publish(DomainEventStreamInterface $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\DomainEventStreamInterface;
6		use Broadway\EventHandling\EventBusInterface;
7		use Broadway\EventHandling\EventListenerInterface;
8		use RemiSan\TransactionManager\TransactionManager;
9
10		class TransactionalEventBus implements EventBusInterface
11		{
12		/**
13		* @var EventBusInterface
14		*/
15		private $eventBus;
16
17		/**
18		* @var TransactionManager
19		*/
20		private $transactionManager;
21
22		/**
23		* @param EventBusInterface $eventBus
24		* @param TransactionManager $transactionManager
25		*/
26	9	public function __construct(EventBusInterface $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 EventListenerInterface $eventListener
36		*/
37	3	public function subscribe(EventListenerInterface $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 DomainEventStreamInterface $domainMessages
46		* @throws \Exception
47		*/
48	6	public function publish(DomainEventStreamInterface $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

Push — master ( 9447a8...2ae261 )

TransactionalEventBus::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like