AMQProxy::Upstream

ClientProperties = AMQ::Protocol::Table.new({ connection_name: System.hostname, product: "AMQProxy", version: VERSION, capabilities: { consumer_priorities: true, exchange_exchange_bindings: true, "connection.blocked": true, authentication_failure_close: true, per_consumer_qos: true, "basic.nack": true, direct_reply_to: true, publisher_confirms: true, consumer_cancel_notify: true, }, })

Log = ::Log.for(self)

new(host : String, port : Int32, tls_ctx : OpenSSL::SSL::Context::Client | Nil, credentials, max_upstream_channels : UInt16 = UInt16::MAX)

close(reason = "")

close_channel(id, code, reason)

open_channel_for(downstream_channel : DownstreamChannel) : UpstreamChannel

read_loop(socket = @socket)

write(frame : AMQ::Protocol::Frame) : Nil