class AMQP::Client::Connection
- AMQP::Client::Connection
- Reference
- Object
Defined in:
amqp-client/connection.cramqp-client/errors.cr
Constant Summary
-
LOG =
AMQP::Client::LOG.for(self)
Constructors
Class Method Summary
Instance Method Summary
- #channel(id : Int | Nil = nil)
- #channel(&blk : Channel -> _)
- #channel_max : UInt16
- #close(msg = "", no_wait = false)
- #closed? : Bool
- #frame_max : UInt32
- #log
- #on_close(&blk : UInt16, String -> )
- #unsafe_write(frame : Frame)
- #with_lock(&blk : self -> _)
- #write(frame : Frame)
Constructor Detail
def self.new(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client, channel_max : UInt16, frame_max : UInt32, heartbeat : UInt16)
#
Class Method Detail
def self.start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client, user, password, vhost, channel_max, frame_max, heartbeat, name : String | Nil)
#