AsynchronousMessageProducer::__invoke() - Code Metrics - tomcizek/symfony-prooph - Measure and Improve Code Quality continuously with Scrutinizer

AsynchronousMessageProducer::__invoke() A
last analyzed 2017-12-08 02:32 UTC

↳ Parent: AsynchronousMessageProducer

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes

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

<?php

namespace TomCizek\SymfonyProoph\AsynchronousMessages;

use Prooph\Common\Messaging\Message;
use Prooph\Common\Messaging\MessageConverter;
use Prooph\ServiceBus\Async\MessageProducer;
use Prooph\ServiceBus\Exception\RuntimeException;
use React\Promise\Deferred;

class AsynchronousMessageProducer implements MessageProducer
{
	/* @var AsynchronousMessageProducerBridge */
	private $producerBridge;

	/** @var MessageConverter */
	private $messageConverter;

	/** @var array */
	private $routes;

	public function __construct(AsynchronousMessageProducerBridge $producerBridge, MessageConverter $messageConverter)
	{
		$this->producerBridge = $producerBridge;
		$this->messageConverter = $messageConverter;
	}

	public function injectRoutes(array $routes)
	{
		$this->routes = $routes;
	}

	public function __invoke(Message $message, Deferred $deferred = null): void
	{
		if ($deferred !== null) {
			throw new RuntimeException(__CLASS__ . ' cannot handle query messages which require future responses.');
		}

		$routingKey = $this->getRoutingKeyFromMessageRoute($message);

		$this->producerBridge->publishWithRoutingKey($message, $routingKey);
	}

	private function getRoutingKeyFromMessageRoute(Message $message): string
	{
		if (empty($this->routes[$message->messageName()])) {
			throw new RuntimeException(
				sprintf(
					'Producer route key for message of name "%s" in asynchronous routing not found.',
					$message->messageName()
				)
			);
		}

		return $this->routes[$message->messageName()];
	}
}


1		<?php
2
3		namespace TomCizek\SymfonyProoph\AsynchronousMessages;
4
5		use Prooph\Common\Messaging\Message;
6		use Prooph\Common\Messaging\MessageConverter;
7		use Prooph\ServiceBus\Async\MessageProducer;
8		use Prooph\ServiceBus\Exception\RuntimeException;
9		use React\Promise\Deferred;
10
11		class AsynchronousMessageProducer implements MessageProducer
12		{
13		/* @var AsynchronousMessageProducerBridge */
14		private $producerBridge;
15
16		/** @var MessageConverter */
17		private $messageConverter;
18
19		/** @var array */
20		private $routes;
21
22	7	public function __construct(AsynchronousMessageProducerBridge $producerBridge, MessageConverter $messageConverter)
23		{
24	7	$this->producerBridge = $producerBridge;
25	7	$this->messageConverter = $messageConverter;
26	7	}
27
28	5	public function injectRoutes(array $routes)
29		{
30	5	$this->routes = $routes;
31	5	}
32
33	4	public function __invoke(Message $message, Deferred $deferred = null): void
34		{
35	4	if ($deferred !== null) {
36	1	throw new RuntimeException(__CLASS__ . ' cannot handle query messages which require future responses.');
37		}
38
39	3	$routingKey = $this->getRoutingKeyFromMessageRoute($message);
40
41	2	$this->producerBridge->publishWithRoutingKey($message, $routingKey);
42	2	}
43
44	3	private function getRoutingKeyFromMessageRoute(Message $message): string
45		{
46	3	if (empty($this->routes[$message->messageName()])) {
47	1	throw new RuntimeException(
48	1	sprintf(
49	1	'Producer route key for message of name "%s" in asynchronous routing not found.',
50	1	$message->messageName()
51		)
52		);
53		}
54
55	2	return $this->routes[$message->messageName()];
56		}
57		}
58

tomcizek / symfony-prooph

AsynchronousMessageProducer::__invoke() A last analyzed 2017-12-08 02:32 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AsynchronousMessageProducer::__invoke() A
last analyzed 2017-12-08 02:32 UTC