RabbitMQFacade::sendMessages() - Code Metrics - Inspection of "+ RabbitMQ Version 1.0.0" - xervice/rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 58d95f...1d35d4 )

by Mike

created 2018-07-27 06:09 UTC

RabbitMQFacade::sendMessages() A

↳ Parent: RabbitMQFacade

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

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

<?php


namespace Xervice\RabbitMQ;


use DataProvider\RabbitMqMessageCollectionDataProvider;
use DataProvider\RabbitMqMessageDataProvider;
use Xervice\Core\Facade\AbstractFacade;

/**
 * @method \Xervice\RabbitMQ\RabbitMQFactory getFactory()
 * @method \Xervice\RabbitMQ\RabbitMQConfig getConfig()
 */
class RabbitMQFacade extends AbstractFacade
{
    /**
     * Initiate the exchanges and queues in RabbitMQ
     *
     * @api
     */
    public function init(): void
    {
        $this->getFactory()->createBootstrapper()->boot();
    }

    /**
     * @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
     */
    public function sendMessage(RabbitMqMessageDataProvider $messageDataProvider): void
    {
        $this->getFactory()->getMessageProvider()->sendMessage($messageDataProvider);
    }

    /**
     * @param \DataProvider\RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider
     */
    public function sendMessages(RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider): void
    {
        $this->getFactory()->getMessageProvider()->sendBulk($messageCollectionDataProvider);
    }

    /**
     * @throws \Xervice\RabbitMQ\Worker\Listener\ListenerException
     */
    public function runWorker(): void
    {
        $this->getFactory()->createWorker()->runWorker();
    }

    public function close(): void
    {
        $this->getFactory()->getConnectionProvider()->getConnection()->close();
    }
}


1		<?php
2
3
4		namespace Xervice\RabbitMQ;
5
6
7		use DataProvider\RabbitMqMessageCollectionDataProvider;
8		use DataProvider\RabbitMqMessageDataProvider;
9		use Xervice\Core\Facade\AbstractFacade;
10
11		/**
12		* @method \Xervice\RabbitMQ\RabbitMQFactory getFactory()
13		* @method \Xervice\RabbitMQ\RabbitMQConfig getConfig()
14		*/
15		class RabbitMQFacade extends AbstractFacade
16		{
17		/**
18		* Initiate the exchanges and queues in RabbitMQ
19		*
20		* @api
21		*/
22	2	public function init(): void
23		{
24	2	$this->getFactory()->createBootstrapper()->boot();
25	2	}
26
27		/**
28		* @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
29		*/
30	1	public function sendMessage(RabbitMqMessageDataProvider $messageDataProvider): void
31		{
32	1	$this->getFactory()->getMessageProvider()->sendMessage($messageDataProvider);
33	1	}
34
35		/**
36		* @param \DataProvider\RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider
37		*/
38	1	public function sendMessages(RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider): void
39		{
40	1	$this->getFactory()->getMessageProvider()->sendBulk($messageCollectionDataProvider);
41	1	}
42
43		/**
44		* @throws \Xervice\RabbitMQ\Worker\Listener\ListenerException
45		*/
46	2	public function runWorker(): void
47		{
48	2	$this->getFactory()->createWorker()->runWorker();
49	2	}
50
51		public function close(): void
52		{
53		$this->getFactory()->getConnectionProvider()->getConnection()->close();
54		}
55		}
56

xervice / rabbitmq

Push — master ( 58d95f...1d35d4 )

RabbitMQFacade::sendMessages() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like