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

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

Instance Method Summary

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

Instance Method Detail