class AMQP::Client::Connection
- AMQP::Client::Connection
- Reference
- Object
Defined in:
amqp-client/connection.cramqp-client/errors.cr
Class Method Summary
-
.start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, user, password, vhost, channel_max, frame_max, heartbeat, name = File.basename(PROGRAM_NAME))
Connection negotiation
Instance Method Summary
-
#channel(id : Int | Nil = nil)
Opens a channel
- #channel(&blk : Channel -> _)
- #channel_max : UInt16
-
#close(reason = "", no_wait = false)
Close the connection the server.
- #closed? : Bool
- #closing_frame : Frame::Connection::Close | Nil
- #frame_max : UInt32
-
#on_close(&blk : UInt16, String -> )
Callback that's called if the
Connectionis closed by the server
Class Method Detail
def self.start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, user, password, vhost, channel_max, frame_max, heartbeat, name = File.basename(PROGRAM_NAME))
#
Connection negotiation
Instance Method Detail
Close the connection the server.
The reason might be logged by the server
def on_close(&blk : UInt16, String -> )
#
Callback that's called if the Connection is closed by the server