OldSound\RabbitMqBundle\Declarations\QueueDeclaration

Complexity

Total Complexity

6

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	setAnonymus()	0	11	1
A	declure()	0	13	5

<?php


namespace OldSound\RabbitMqBundle\Declarations;

/**
 * @TODO move
 */
class QueueDeclaration
{
    public $name;
    public $passive;
    public $durable;
    public $exclusive;
    public $autoDelete;
    public $nowait;
    public $arguments;
    public $ticket;
    public $declare;

    // TODO remove
    public function setAnonymus()
    {
        $this->setQueueOptions(array(

The method setQueueOptions() does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration.

            'name' => '',
            'passive' => false,
            'durable' => false,
            'exclusive' => true,
            'auto_delete' => true,
            'nowait' => false,
            'arguments' => null,
            'ticket' => null
        ));
    }

    /**
     *  TODO delete
     */
    public function declure() {
        foreach ($this->queues as $name => $options) {

The property queues does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration. Did you maybe forget to declare it?

            list($queueName, ,) = $this->getChannel()->queue_declare($name, $options['passive'],

The method getChannel() does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration.

                $options['durable'], $options['exclusive'],
                $options['auto_delete'], $options['nowait'],
                $options['arguments'], $options['ticket']);

            if (isset($options['routing_keys']) && count($options['routing_keys']) > 0) {
                foreach ($options['routing_keys'] as $routingKey) {
                    $this->queueBind($queueName, $this->exchangeOptions['name'], $routingKey, $options['arguments'] ?? []);

The property exchangeOptions does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration. Did you maybe forget to declare it?

The method queueBind() does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration.

                }
            } else {
                $this->queueBind($queueName, $this->exchangeOptions['name'], $this->routingKey, $options['arguments'] ?? []);

The property routingKey does not exist on OldSound\RabbitMqBundle\Declarations\QueueDeclaration. Did you maybe forget to declare it?

            }
        }
    }
}