AMQProxy::Client
Constants
CLOSE_TIMEOUT = 5.seconds
How long a client gets to answer our Connection#Close before we close the socket, a client that never reads would otherwise stay connected forever
FRAME_MAX = 131072_u32
The largest frame we offer the client in Connection#Tune, the client can only negotiate it down, so it's also the limit we enforce when reading
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,
},
})
Constructors
Instance methods
close
Sourceclose_channel(id, code, reason)
Sourceclose_connection(code, text, frame = nil)
Sourceclose_socket
Sourcecredentials
Sourcewrite(frame : AMQ::Protocol::Frame)
Send frame to client, channel id should already be remapped by the caller