src/Queue/Queue.php
public function initialize(\AMQPQueue $queue = null)
    {
        if (true === $this->isInitialized()) {
            throw new HectorException('Queue already initialized');
        }

        if (null === $queue) {
            $queue = new \AMQPQueue($this->channel->getWrappedChannel());
        }

        $this->queue = $queue;
        $this->queue->setName($this->getName());
        $this->queue->bind($this->exchange->getName());
        $this->queue->setFlags($this->context->getFlags());
        $this->queue->setArguments($this->context->getArguments());
        $this->queue->declareQueue();
        $this->initialized = true;
    }
public function initialize(\AMQPQueue $queue = null)
    {
        if (true === $this->isInitialized()) {
            throw new HectorException('Queue already initialized');
        }

        if (null === $queue) {
            $queue = new \AMQPQueue($this->channel->getWrappedChannel());
        }

        $this->queue = $queue;
        $this->queue->setName($this->getName());
        $this->queue->bind($this->exchange->getName());
        $this->queue->setFlags($this->context->getFlags());
        $this->queue->setArguments($this->context->getArguments());
        $this->queue->declareQueue();
        $this->initialized = true;
    }
@param \AMQPQueue|null $queue

@throws HectorException