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

@throws \Exception

@return Exchange