module AvalancheMQ::AMQPConnection

Defined in:

avalanchemq/client/amqp_connection.cr

Constant Summary

SERVER_PROPERTIES = AMQP::Table.new({"product" => "AvalancheMQ", "platform" => "Crystal #{Crystal::VERSION}", "version" => AvalancheMQ::VERSION, "capabilities" => AMQP::Table.new({"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, users, start_ok, log)
• .close_on_ok(socket, log)
• .confirm_header(socket, log)
• .credentials(start_ok)
• .open(socket, vhosts, user, log)
• .start(socket, remote_address, local_address, vhosts, users, log, events)
• .start(socket, log)
• .tune(socket, log)

Class Method Detail