AMQProxy::Client

Log = ::Log.for(self)

ServerProperties = AMQ::Protocol::Table.new({ 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, }, })

new(socket : TCPSocket)

close_channel(id, code, reason)

close_connection(code, text, frame = nil)

read_loop(channel_pool, socket = @socket)

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