Metfan\RabbitSetup\Manager\RabbitMq\ExchangeManager

Complexity

Total Complexity

4

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	12	2
A	getAll()	0	4	1
A	delete()	0	4	1

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

use Metfan\RabbitSetup\Http\ClientInterface;

/**
 * Exchange manager, create, retrieve, delete
 *
 * @author Ulrich
 * @package Metfan\RabbitSetup\Manager
 */
class ExchangeManager extends BaseManager
{
    /**
     * Create an exchange
     *
     * @param string $exchangeName
     * @param array $options
     * @return void
     */
    public function create($exchangeName, array $options)
    {
        if (empty($options['arguments'])) {
            unset($options['arguments']);
        }

        $this->client->query(
            ClientInterface::METHOD_PUT,
            sprintf('/api/exchanges/%s/%s', $this->vhost, $exchangeName),
            $options);
        $this->logger->info(sprintf('Create exchange: <info>%s</info>', $exchangeName));
    }

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

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