class LavinMQ::AMQPConnection

• LavinMQ::AMQPConnection
• Reference
• Object

Defined in:

lavinmq/client/amqp_connection.cr

Constant Summary

Log = ::Log.for("AMQPConnection")

SERVER_PROPERTIES = AMQP::Table.new({product: "LavinMQ", platform: "Crystal #{Crystal::VERSION}", version: LavinMQ::VERSION, capabilities: {publisher_confirms: true, exchange_exchange_bindings: true, "basic.nack": true, consumer_cancel_notify: true, "connection.blocked": true, consumer_priorities: true, authentication_failure_close: true, per_consumer_qos: true, direct_reply_to: true}})

Class Method Summary

• .authenticate(socket, remote_address, users, start_ok)
• .confirm_header(socket) : Bool
• .credentials(start_ok)
• .open(socket, vhosts, user)
• .start(socket, connection_info, vhosts, users) : Client | Nil
• .start(socket)
• .tune(socket)

Class Method Detail