ccovey / rabbitmq

     *

     * @return ChannelInterface

     */

    public function declareQueue(Queue $queue) : ChannelInterface

    {

        $this->channel->queue_declare(

            $queue->getQueueName(),

            $queue->isPassive(),

            $queue->isDurable(),

            $queue->isExclusive(),

            $queue->isAutoDelete(),

            $queue->isNoWait(),

            $queue->getArguments(),

            $queue->getTicket()

        );

        return $this;

    }

    public function bindQueue(Queue $queue) : ChannelInterface

    {

        return $this;

    }

    public function declareExchange(Exchange $exchange) : ChannelInterface

    {

        $this->channel->exchange_declare(

            $exchange->getExchange(),

            $exchange->getType(),

            $exchange->isPassive(),

            $exchange->isDurable(),

            $exchange->isAutoDelete(),

            $exchange->isInternal(),

            $exchange->isNoWait(),

            $exchange->getArguments(),

            $exchange->getTicket()

        );

        return $this;

    }

    /**

     * @return array