contamobi / CmobiRabbitmqBundle

    private $resolver;

    private $options;

    public function __construct(

        $queueName,

        $basicQos = 1,

        $durable = false,

        $autoDelete = true,

        array $arguments = null

    ) {

        $this->resolver = new OptionsResolver();

        $this->resolver->setDefaults([

            'queue_name' => $queueName,

            'basic_qos' => $basicQos,

            'durable' => $durable,

            'auto_delete' => $autoDelete,

            'arguments' => $arguments

        ]);

        $this->options = $this->resolver->resolve([]);

    }

    /**

     * @param $queue

    private $resolver;

    private $options;

    public function __construct(

        $exchangeName,

        $type = ExchangeType::FANOUT,

        $queueName = null,

        $basicQos = 1,

        array $arguments = null

    ) {

        $this->resolver = new OptionsResolver();

        $this->resolver->setDefaults([

            'exchange' => $exchangeName,

            'type' => $type,

            'queue_name' => $queueName,

            'basic_qos' => $basicQos,

            'arguments' => $arguments

        ]);

        $this->options = $this->resolver->resolve([]);

    }

    /**

     * @param $exchange