class AMQP::Client
- AMQP::Client
- Reference
- Object
Defined in:
amqp-client.cramqp-client/channel.cr
amqp-client/connection.cr
amqp-client/errors.cr
amqp-client/exchange.cr
amqp-client/message.cr
amqp-client/queue.cr
amqp-client/sync.cr
amqp-client/version.cr
amqp-client/websocket_io.cr
Constant Summary
-
LOG =
::Log.for(self) -
SCHEME_PORT =
{"amqp" => 5672, "amqps" => 5671, "ws" => 80, "wss" => 443, "http" => 80, "https" => 443} -
TLS_SCHEMES =
["amqps", "wss", "https"] of ::String -
VERSION =
"0.6.6" -
WS_SCHEMES =
["ws", "wss", "http", "https"] of ::String
Constructors
- .new(url : String)
- .new(uri : URI)
- .new(host : String = "localhost", port : Int32 = 5672, vhost : String = "/", user : String = "guest", password : String = "guest", tls : Bool = false, websocket : Bool = false, channel_max : UInt16 = 1024_u16, frame_max : UInt32 = 131072_u32, heartbeat : UInt16 = 0_u16, verify_mode : LibSSL::VerifyMode = OpenSSL::SSL::VerifyMode::PEER, name : String | Nil = File.basename(PROGRAM_NAME))
Class Method Summary
- .start(url : String | URI, &blk : AMQP::Client::Connection -> _)
- .start(host = "localhost", port = 5672, vhost = "/", user = "guest", password = "guest", tls = false, websocket = false, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, &blk : AMQP::Client::Connection -> _)
Instance Method Summary
Constructor Detail
def self.new(host : String = "localhost", port : Int32 = 5672, vhost : String = "/", user : String = "guest", password : String = "guest", tls : Bool = false, websocket : Bool = false, channel_max : UInt16 = 1024_u16, frame_max : UInt32 = 131072_u32, heartbeat : UInt16 = 0_u16, verify_mode : LibSSL::VerifyMode = OpenSSL::SSL::VerifyMode::PEER, name : String | Nil = File.basename(PROGRAM_NAME))
#
Class Method Detail
def self.start(host = "localhost", port = 5672, vhost = "/", user = "guest", password = "guest", tls = false, websocket = false, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, &blk : AMQP::Client::Connection -> _)
#