class LavinMQ::AMQP::ConnectionFactory

• LavinMQ::AMQP::ConnectionFactory
• LavinMQ::ConnectionFactory
• Reference
• Object

Defined in:

lavinmq/amqp/connection_factory.cr

Constant Summary

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

Constructors

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

Instance Method Summary

• #authenticate(socket, remote_address, start_ok, log)
• #confirm_header(socket, log : Logger) : Bool
• #credentials(start_ok)
• #open(socket, user, log)
• #start(socket, log : Logger)
• #start(socket, connection_info) : Client | Nil
• #tune(socket, log)

Constructor Detail

Instance Method Detail