RabbitMQFactory::createWorker() - 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

RabbitMQFactory::createWorker() A

↳ Parent: RabbitMQFactory

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php


namespace Xervice\RabbitMQ;


use Xervice\Core\Factory\AbstractFactory;
use Xervice\RabbitMQ\Core\Bootstrapper;
use Xervice\RabbitMQ\Core\ConnectionProvider;
use Xervice\RabbitMQ\Core\ConnectionProviderInterface;
use Xervice\RabbitMQ\Core\ExchangeProvider;
use Xervice\RabbitMQ\Core\ExchangeProviderInterface;
use Xervice\RabbitMQ\Core\QueueProvider;
use Xervice\RabbitMQ\Core\QueueProviderInterface;
use Xervice\RabbitMQ\Exchange\ExchangeBuilder;
use Xervice\RabbitMQ\Message\MessageProvider;
use Xervice\RabbitMQ\Message\MessageProviderInterface;
use Xervice\RabbitMQ\Queue\QueueBuilder;
use Xervice\RabbitMQ\Worker\Consumer\Consumer;
use Xervice\RabbitMQ\Worker\Consumer\ConsumerInterface;
use Xervice\RabbitMQ\Worker\Listener\ListenerInterface;
use Xervice\RabbitMQ\Worker\Worker;
use Xervice\RabbitMQ\Worker\WorkerInterface;

/**
 * @method \Xervice\RabbitMQ\RabbitMQConfig getConfig()
 */
class RabbitMQFactory extends AbstractFactory
{
    /**
     * @var ConnectionProviderInterface
     */
    private $connection;

    /**
     * @var MessageProviderInterface
     */
    private $messageProvider;

    /**
     * @return \Xervice\RabbitMQ\Core\BootstrapperInterface
     */
    public function createBootstrapper()
    {
        return new Bootstrapper(
            $this->createExchangeBuilder(),
            $this->createQueueBuilder()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Worker\WorkerInterface
     */
    public function createWorker(): WorkerInterface
    {
        return new Worker(
            $this->getListenerCollection(),
            $this->createConsumer()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Worker\Consumer\ConsumerInterface
     */
    public function createConsumer(): ConsumerInterface
    {
        return new Consumer(
            $this->getConnectionProvider()->getChannel(),
            $this->getConfig()->getConsumerConfig()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Queue\QueueBuilder
     */
    public function createQueueBuilder()
    {
        return new QueueBuilder(
            $this->createQueueProvider(),
            $this->getQueueCollection()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Exchange\ExchangeBuilder
     */
    public function createExchangeBuilder()
    {
        return new ExchangeBuilder(
            $this->createExchangeProvider(),
            $this->getExchangeCollection()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Core\ExchangeProviderInterface
     */
    public function createExchangeProvider() : ExchangeProviderInterface
    {
        return new ExchangeProvider(
            $this->getConnectionProvider()->getChannel()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Core\QueueProviderInterface
     */
    public function createQueueProvider() : QueueProviderInterface
    {
        return new QueueProvider(
            $this->getConnectionProvider()->getChannel()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Message\MessageProviderInterface
     */
    public function createMessageProvider() : MessageProviderInterface
    {
        return new MessageProvider(
            $this->getConnectionProvider()->getChannel()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Core\ConnectionProviderInterface
     */
    public function createConnectionProvider() : ConnectionProviderInterface
    {
        return new ConnectionProvider(
            $this->getConfig()->getConnectionConfig()
        );
    }

    /**
     * @return \Xervice\RabbitMQ\Message\MessageProviderInterface
     */
    public function getMessageProvider() : MessageProviderInterface
    {
        if ($this->messageProvider === null) {
            $this->messageProvider = $this->createMessageProvider();
        }

        return $this->messageProvider;
    }

    /**
     * @return \Xervice\RabbitMQ\Core\ConnectionProviderInterface
     */
    public function getConnectionProvider() : ConnectionProviderInterface
    {
        if ($this->connection === null) {
            $this->connection = $this->createConnectionProvider();
        }

        return $this->connection;
    }

    /**
     * @return \Xervice\RabbitMQ\Exchange\ExchangeCollection
     */
    public function getExchangeCollection()
    {
        return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_EXCHANGES);
    }

    /**
     * @return \Xervice\RabbitMQ\Queue\QueueCollection
     */
    public function getQueueCollection()
    {
        return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_QUEUES);
    }

    /**
     * @return \Xervice\RabbitMQ\Worker\Listener\ListenerCollection
     */
    public function getListenerCollection()
    {
        return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_LISTENER);
    }

}

1			<?php
2
3
4			namespace Xervice\RabbitMQ;
5
6
7			use Xervice\Core\Factory\AbstractFactory;
8			use Xervice\RabbitMQ\Core\Bootstrapper;
9			use Xervice\RabbitMQ\Core\ConnectionProvider;
10			use Xervice\RabbitMQ\Core\ConnectionProviderInterface;
11			use Xervice\RabbitMQ\Core\ExchangeProvider;
12			use Xervice\RabbitMQ\Core\ExchangeProviderInterface;
13			use Xervice\RabbitMQ\Core\QueueProvider;
14			use Xervice\RabbitMQ\Core\QueueProviderInterface;
15			use Xervice\RabbitMQ\Exchange\ExchangeBuilder;
16			use Xervice\RabbitMQ\Message\MessageProvider;
17			use Xervice\RabbitMQ\Message\MessageProviderInterface;
18			use Xervice\RabbitMQ\Queue\QueueBuilder;
19			use Xervice\RabbitMQ\Worker\Consumer\Consumer;
20			use Xervice\RabbitMQ\Worker\Consumer\ConsumerInterface;
21			use Xervice\RabbitMQ\Worker\Listener\ListenerInterface;
22			use Xervice\RabbitMQ\Worker\Worker;
23			use Xervice\RabbitMQ\Worker\WorkerInterface;
24
25			/**
26			* @method \Xervice\RabbitMQ\RabbitMQConfig getConfig()
27			*/
28			class RabbitMQFactory extends AbstractFactory
29			{
30			/**
31			* @var ConnectionProviderInterface
32			*/
33			private $connection;
34
35			/**
36			* @var MessageProviderInterface
37			*/
38			private $messageProvider;
39
40			/**
41			* @return \Xervice\RabbitMQ\Core\BootstrapperInterface
42			*/
43			public function createBootstrapper()
44			{
45			return new Bootstrapper(
46			$this->createExchangeBuilder(),
47			$this->createQueueBuilder()
48			);
49			}
50
51			/**
52			* @return \Xervice\RabbitMQ\Worker\WorkerInterface
53			*/
54			public function createWorker(): WorkerInterface
55			{
56			return new Worker(
57			$this->getListenerCollection(),
58			$this->createConsumer()
59			);
60			}
61
62			/**
63			* @return \Xervice\RabbitMQ\Worker\Consumer\ConsumerInterface
64			*/
65			public function createConsumer(): ConsumerInterface
66			{
67			return new Consumer(
68			$this->getConnectionProvider()->getChannel(),
69			$this->getConfig()->getConsumerConfig()
70			);
71			}
72
73			/**
74			* @return \Xervice\RabbitMQ\Queue\QueueBuilder
75			*/
76			public function createQueueBuilder()
77			{
78			return new QueueBuilder(
79			$this->createQueueProvider(),
80			$this->getQueueCollection()
81			);
82			}
83
84			/**
85			* @return \Xervice\RabbitMQ\Exchange\ExchangeBuilder
86			*/
87			public function createExchangeBuilder()
88			{
89			return new ExchangeBuilder(
90			$this->createExchangeProvider(),
91			$this->getExchangeCollection()
92			);
93			}
94
95			/**
96			* @return \Xervice\RabbitMQ\Core\ExchangeProviderInterface
97			*/
98			public function createExchangeProvider() : ExchangeProviderInterface
99			{
100			return new ExchangeProvider(
101			$this->getConnectionProvider()->getChannel()
102			);
103			}
104
105			/**
106			* @return \Xervice\RabbitMQ\Core\QueueProviderInterface
107			*/
108			public function createQueueProvider() : QueueProviderInterface
109			{
110			return new QueueProvider(
111			$this->getConnectionProvider()->getChannel()
112			);
113			}
114
115			/**
116			* @return \Xervice\RabbitMQ\Message\MessageProviderInterface
117			*/
118			public function createMessageProvider() : MessageProviderInterface
119			{
120			return new MessageProvider(
121			$this->getConnectionProvider()->getChannel()
122			);
123			}
124
125			/**
126			* @return \Xervice\RabbitMQ\Core\ConnectionProviderInterface
127			*/
128			public function createConnectionProvider() : ConnectionProviderInterface
129			{
130			return new ConnectionProvider(
131			$this->getConfig()->getConnectionConfig()
132			);
133			}
134
135			/**
136			* @return \Xervice\RabbitMQ\Message\MessageProviderInterface
137			*/
138			public function getMessageProvider() : MessageProviderInterface
139			{
140			if ($this->messageProvider === null) {
141			$this->messageProvider = $this->createMessageProvider();
142			}
143
144			return $this->messageProvider;
145			}
146
147			/**
148			* @return \Xervice\RabbitMQ\Core\ConnectionProviderInterface
149			*/
150			public function getConnectionProvider() : ConnectionProviderInterface
151			{
152			if ($this->connection === null) {
153			$this->connection = $this->createConnectionProvider();
154			}
155
156			return $this->connection;
157			}
158
159			/**
160			* @return \Xervice\RabbitMQ\Exchange\ExchangeCollection
161			*/
162			public function getExchangeCollection()
163			{
164			return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_EXCHANGES);
165			}
166
167			/**
168			* @return \Xervice\RabbitMQ\Queue\QueueCollection
169			*/
170			public function getQueueCollection()
171			{
172			return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_QUEUES);
173			}
174
175			/**
176			* @return \Xervice\RabbitMQ\Worker\Listener\ListenerCollection
177			*/
178			public function getListenerCollection()
179			{
180			return $this->getDependency(RabbitMQDependencyProvider::RABBITMQ_LISTENER);
181			}
182
183			}

xervice / rabbitmq

Push — master ( b520c6...4ddac5 )

RabbitMQFactory::createWorker() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like