LavinMQ::AMQP::ConnectionFactory

Log = LavinMQ::Log.for("amqp.connection_factory")

LOW_FRAME_MAX_RANGE = 1...MIN_FRAME_MAX

MIN_FRAME_MAX = 4096_u32

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, }, })

new(authenticator : Auth::Authenticator, vhosts : VHostStore)

authenticate(socket, connection_info : ConnectionInfo, start_ok, log)

confirm_header(socket, log : Logger) : Bool

create(socket, connection_info) : Client | Nil

credentials(start_ok)

open(socket, user, log)

start(socket, log : Logger)

tune(socket, log)