Metfan\RabbitSetup\Manager\RabbitMq\QueueManager

Complexity

Total Complexity

5

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	create()	0	28	3
A	getAll()	0	4	1
A	delete()	0	4	1

<?php
namespace Metfan\RabbitSetup\Manager\RabbitMq;

use Metfan\RabbitSetup\Http\ClientInterface;

/**
 * Queue manager, create, retrieve, delete queue and bind queues to exchange
 *
 * @author Ulrich
 * @package Metfan\RabbitSetup\Manager
 */
class QueueManager extends BaseManager
{
    /**
     * Create a queue
     *
     * @param $queueName
     * @param array $options
     * @return void
     */
    public function create($queueName, array $options)
    {
        if (empty($options['arguments'])) {
            unset($options['arguments']);
        }

        $bindings = $options['bindings'];
        unset($options['bindings']);

        $this->client->query(
            ClientInterface::METHOD_PUT,
            sprintf('/api/queues/%s/%s', $this->vhost, $queueName),
            $options);
        $this->logger->info(sprintf('Create queue: <info>%s</info>', $queueName));

        foreach($bindings as $binding) {
            $this->client->query(
                ClientInterface::METHOD_POST,
                sprintf('/api/bindings/%s/e/%s/q/%s', $this->vhost, $binding['exchange'], $queueName),
                ['routing_key' => $binding['routing_key']]);
            $this->logger->info(sprintf(
                'Bind exchange <info>%s</info> with queue <info>%s</info> using routing key <info>%s</info>',
                $binding['exchange'],
                $queueName,
                $binding['routing_key']));
        }

    }

    /**
     * Get all queue from a vhost or all queue in your rabbitmq
     *
     * @param string|null $vhost
     * @return mixed
     */
    public function getAll($vhost = null)
    {
        return $this->findAllElements('/api/queues', $vhost);
    }

    /**
     * Delete a queue from a vhost
     *
     * @param $vhost
     * @param $name
     * @return mixed
     */
    public function delete($vhost, $name)
    {
        return $this->deleteElement('/api/queues', $vhost, $name, 'queue');
    }
}