src/Exchange/ExchangeRegistry.php
public function getExchange($name, Channel $channel)
    {
        /*
         * @var string
         * @var Exchange
         */
        foreach ($this->exchanges as $exchange) {
            if ($exchange->isEqual($name, $channel)) {
                return $exchange;
            }
        }

        throw new NotFoundException(sprintf(
            'Unable to find exchange %s for channel %s',
            $name,
            $channel->getIdentity()
        ));
    }
public function getExchange($name, Channel $channel)
    {
        /*
         * @var string
         * @var Exchange
         */
        foreach ($this->exchanges as $exchange) {
            if ($exchange->isEqual($name, $channel)) {
                return $exchange;
            }
        }

        throw new NotFoundException(sprintf(
            'Unable to find exchange %s for channel %s',
            $name,
            $channel->getIdentity()
        ));
    }
public function getExchange ( $ name , Channel $ channel ) { /*
         * @var string
         * @var Exchange
         */ foreach ( $ this -> exchanges as $ exchange ) { if ( $ exchange -> isEqual ( $ name , $ channel ) ) { return $ exchange ; } } throw new NotFoundException ( sprintf ( 'Unable to find exchange %s for channel %s' , $ name , $ channel -> getIdentity ( ) ) ) ; }
@param string  $name
@param Channel $channel

@throws \Exception

@return Exchange
@param string $name @param Channel $channel