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