class AMQProxy::Upstream

Defined in:

amqproxy/upstream.cr

Constant Summary

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)

Constructors

Instance Method Summary

Constructor Detail

def self.new(host : String, port : Int32, tls_ctx : OpenSSL::SSL::Context::Client | Nil, credentials) #

[View source]

Instance Method Detail

def channels #

[View source]
def close(reason = "") #

[View source]
def close_channel(id, code, reason) #

[View source]
def closed? #

[View source]
def open_channel_for(downstream_channel : DownstreamChannel) : UpstreamChannel #

[View source]
def read_loop(socket = @socket) #

Frames from upstream (to client)


[View source]
def write(frame : AMQ::Protocol::Frame) : Nil #

Forward frames from client to upstream


[View source]