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
-
VERSION =
{{ (`shards version`).stringify }}
Constructors
- .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 : Bool = AMQP_TLS, websocket : Bool = AMQP_WS, 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), tcp_nodelay : Bool = false, tcp_keepalive : NamedTuple(idle: Int32, interval: Int32, count: Int32) = {idle: 60, interval: 10, count: 3})
Class Method Summary
- .start(url : String | URI, &blk : AMQP::Client::Connection -> _)
- .start(host = AMQP_HOST, port = AMQP_PORT, vhost = AMQP_VHOST, user = AMQP_USER, password = AMQP_PASS, tls = AMQP_TLS, websocket = AMQP_WS, 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
Establish a connection
- #host : String
- #port : Int32
- #tls : Bool
- #user : String
- #vhost : String
- #websocket : Bool
Constructor Detail
def self.new(host : String = AMQP_HOST, port : Int32 = AMQP_PORT, vhost : String = AMQP_VHOST, user : String = AMQP_USER, password : String = AMQP_PASS, tls : Bool = AMQP_TLS, websocket : Bool = AMQP_WS, 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), tcp_nodelay : Bool = false, tcp_keepalive : NamedTuple(idle: Int32, interval: Int32, count: Int32) = {idle: 60, interval: 10, count: 3})
#
Class Method Detail
def self.start(host = AMQP_HOST, port = AMQP_PORT, vhost = AMQP_VHOST, user = AMQP_USER, password = AMQP_PASS, tls = AMQP_TLS, websocket = AMQP_WS, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, &blk : AMQP::Client::Connection -> _)
#