AMQP::Client

VERSION = "1.3.2"

new(url : String)

new(uri : URI)

new(host : String = AMQP_HOST, port : Int32 = AMQP_PORT, vhost : String = AMQP_VHOST, user : String = AMQP_USER, password : String = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket : Bool = AMQP_WS, channel_max : UInt16 = 1024_u16, frame_max : UInt32 = 131072_u32, heartbeat : UInt16 = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name : String | Nil = File.basename(PROGRAM_NAME), connection_information : AMQP::Client::ConnectionInformation = ConnectionInformation.new("amqp-client.cr", AMQP::Client::VERSION, "Crystal", Crystal::VERSION, File.basename(PROGRAM_NAME)), tcp : AMQP::Client::TCPConfig = TCPConfig.new, buffer_size : Int32 = 16384)

start(url : String | URI, & : AMQP::Client::Connection -> _)

start(host = AMQP_HOST, port = AMQP_PORT, vhost = AMQP_VHOST, user = AMQP_USER, password = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket = AMQP_WS, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, connection_information = ConnectionInformation.new, & : AMQP::Client::Connection -> _)

buffer_size=(buffer_size : Int32)

host=(host : String)

port=(port : Int32)

tcp=(tcp : AMQP::Client::TCPConfig)

tls=(tls : OpenSSL::SSL::Context::Client | Nil)

user=(user : String)

vhost=(vhost : String)

websocket=(websocket : Bool)