public function queue($name, $options = [])
    {
        if (empty($this->_queues[$name])) {
            $channel = $this->channel($name, $options);
            $queue = new AMQPQueue($channel);
            $queue->setName($name);

            if (!empty($options['flags'])) {
                $queue->setFlags($options['flags']);
            }

            $this->_queues[$name] = $queue;
        }

        return $this->_queues[$name];
    }