class AMQProxy::Client

• AMQProxy::Client
• Reference
• Object

Defined in:

amqproxy/client.cr

Constant Summary

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

• .new(socket : TCPSocket)

Instance Method Summary

• #close
• #close_channel(id, code, reason)
• #close_connection(code, text, frame = nil)
• #close_socket
• #credentials : Credentials
• #read_loop(channel_pool, socket = @socket)

  frames from enduser

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

  Send frame to client, channel id should already be remapped by the caller

Constructor Detail

Instance Method Detail