Xervice\RabbitMQ\Business\RabbitMQFacade

Complexity

Total Complexity

7

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Test Coverage

Coverage

83.33%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	runWorker()	0	6	1
A	consumeQueries()	0	5	1
A	reconnect()	0	7	1
A	init()	0	6	1
A	sendMessages()	0	6	1
A	close()	0	7	1
A	sendMessage()	0	6	1

<?php
declare(strict_types=1);

namespace Xervice\RabbitMQ\Business;

use DataProvider\RabbitMqMessageCollectionDataProvider;
use DataProvider\RabbitMqMessageDataProvider;
use Symfony\Component\Console\Output\OutputInterface;
use Xervice\Core\Business\Model\Facade\AbstractFacade;
use Xervice\RabbitMQ\Business\Dependency\Worker\Listener\ListenerInterface;


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

    /**
     * @param \Xervice\RabbitMQ\Business\Dependency\Worker\Listener\ListenerInterface $listener
     */
    public function consumeQueries(ListenerInterface $listener): void
    {
        $this->getFactory()
             ->createConsumer($listener)
             ->consumeQueries();
    }

    public function runWorker(OutputInterface $output = null): void
    {
        $this
            ->getFactory()
            ->createWorker()
            ->runWorker($output);
    }

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

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

    /**
     * @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);
    }
}