ImmediateDispatchTerminator::terminate() - Code Metrics - phpservicebus/core - Measure and Improve Code Quality continuously with Scrutinizer

ImmediateDispatchTerminator::terminate() A
last analyzed 2020-01-22 17:49 UTC

↳ Parent: ImmediateDispatchTerminator

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	3
cts	3
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php
namespace PSB\Core\Pipeline\Outgoing;


use PSB\Core\Pipeline\Outgoing\StageContext\DispatchContext;
use PSB\Core\Pipeline\PipelineTerminator;
use PSB\Core\Transport\MessageDispatcherInterface;
use PSB\Core\Transport\TransportOperations;

class ImmediateDispatchTerminator extends PipelineTerminator
{
    /**
     * @var MessageDispatcherInterface
     */
    private $messageDispatcher;

    /**
     * @param MessageDispatcherInterface $messageDispatcher
     */
    public function __construct(MessageDispatcherInterface $messageDispatcher)
    {
        $this->messageDispatcher = $messageDispatcher;
    }

    /**
     * @param DispatchContext $context
     */
    protected function terminate($context)
    {
        $this->messageDispatcher->dispatch(new TransportOperations($context->getTransportOperations()));
    }

    /**
     * @return string
     */
    public static function getStageContextClass()
    {
        return DispatchContext::class;
    }

    /**
     * @return string
     */
    public static function getNextStageContextClass()
    {
        return '';
    }
}


1		<?php
2		namespace PSB\Core\Pipeline\Outgoing;
3
4
5		use PSB\Core\Pipeline\Outgoing\StageContext\DispatchContext;
6		use PSB\Core\Pipeline\PipelineTerminator;
7		use PSB\Core\Transport\MessageDispatcherInterface;
8		use PSB\Core\Transport\TransportOperations;
9
10		class ImmediateDispatchTerminator extends PipelineTerminator
11		{
12		/**
13		* @var MessageDispatcherInterface
14		*/
15		private $messageDispatcher;
16
17		/**
18		* @param MessageDispatcherInterface $messageDispatcher
19		*/
20	4	public function __construct(MessageDispatcherInterface $messageDispatcher)
21		{
22	4	$this->messageDispatcher = $messageDispatcher;
23	4	}
24
25		/**
26		* @param DispatchContext $context
27		*/
28	1	protected function terminate($context)
29		{
30	1	$this->messageDispatcher->dispatch(new TransportOperations($context->getTransportOperations()));
31	1	}
32
33		/**
34		* @return string
35		*/
36	1	public static function getStageContextClass()
37		{
38	1	return DispatchContext::class;
39		}
40
41		/**
42		* @return string
43		*/
44	1	public static function getNextStageContextClass()
45		{
46	1	return '';
47		}
48		}
49

phpservicebus / core

ImmediateDispatchTerminator::terminate() A last analyzed 2020-01-22 17:49 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ImmediateDispatchTerminator::terminate() A
last analyzed 2020-01-22 17:49 UTC