src/Queue/QueueRegistry.php
public function getQueue($name, Channel $channel, Exchange $exchange)
    {
        /*
         * @var string
         * @var Queue
         */
        foreach ($this->queues as $fingerPrint => $queue) {
            if ($queue->isEqual($name, $channel, $exchange)) {
                return $queue;
            }
        }

        throw new NotFoundException(sprintf(
            'Unable to find queue %s for channel %s and exchange %s',
            $name,
            $channel->getIdentity(),
            $exchange->getName()
        ));
    }
public function getQueue($name, Channel $channel, Exchange $exchange)
    {
        /*
         * @var string
         * @var Queue
         */
        foreach ($this->queues as $fingerPrint => $queue) {
            if ($queue->isEqual($name, $channel, $exchange)) {
                return $queue;
            }
        }

        throw new NotFoundException(sprintf(
            'Unable to find queue %s for channel %s and exchange %s',
            $name,
            $channel->getIdentity(),
            $exchange->getName()
        ));
    }
@param string   $name
@param Channel  $channel
@param Exchange $exchange

@throws \Exception

@return Queue