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()
        ));
    }
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
@param string $name @param Channel $channel @param Exchange $exchange