# File lib/reactor/connector.rb, line 75
    def connect(connection)
      url = @address.next
      connection.hostname = "#{url.host}:#{url.port}"

      transport = Qpid::Proton::Transport.new
      transport.bind(connection)
      if !@heartbeat.nil?
        transport.idle_timeout = @heartbeat
      elsif (url.scheme == "amqps") && !@ssl_domain.nil?
        @ssl = Qpid::Proton::SSL.new(transport, @ssl_domain)
        @ss.peer_hostname = url.host
      elsif !url.username.nil?
        sasl = transport.sasl
        if url.username == "anonymous"
          sasl.mechanisms("ANONYMOUS")
        else
          sasl.plain(url.username, url.password)
        end
      end
    end