RabbitMQFacade::runWorker() - Code Metrics - Inspection of "+ Default RabbitMQ version" - xervice/rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b520c6...4ddac5 )

by Mike

created 2018-07-26 09:30 UTC

RabbitMQFacade::runWorker() A

↳ Parent: RabbitMQFacade

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	1
dl	0
loc	3
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	0

<?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			public function init(): void
23			{
24			$this->getFactory()->createBootstrapper()->boot();
25			}
26
27			/**
28			* @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
29			*/
30			public function sendMessage(RabbitMqMessageDataProvider $messageDataProvider): void
31			{
32			$this->getFactory()->getMessageProvider()->sendMessage($messageDataProvider);
33			}
34
35			/**
36			* @param \DataProvider\RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider
37			*/
38			public function sendMessages(RabbitMqMessageCollectionDataProvider $messageCollectionDataProvider): void
39			{
40			$this->getFactory()->getMessageProvider()->sendBulk($messageCollectionDataProvider);
41			}
42
43			/**
44			* @throws \Xervice\RabbitMQ\Worker\Listener\ListenerException
45			*/
46			public function runWorker(): void
47			{
48			$this->getFactory()->createWorker()->runWorker();
49			}
50
51			public function close(): void
52			{
53			$this->getFactory()->getConnectionProvider()->getConnection()->close();
54			}
55			}
56

xervice / rabbitmq

Push — master ( b520c6...4ddac5 )

RabbitMQFacade::runWorker() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like