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 =
{{ (`shards version`).stringify }} -
WS_SCHEMES =
["ws", "wss", "http", "https"] of ::String
Constructors
- .new(url : String)
- .new(uri : URI)
- .new(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 : String? = File.basename(PROGRAM_NAME), tcp_nodelay = false, tcp_keepalive = {idle: 60, interval: 10, count: 3})
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
- #connect : Connection
- #host : String
- #port : Int32
- #tls : Bool
- #user : String
- #vhost : String
- #websocket : Bool
Constructor Detail
def self.new(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 : String? = File.basename(PROGRAM_NAME), tcp_nodelay = false, tcp_keepalive = {idle: 60, interval: 10, count: 3})
#
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 -> _)
#