class AMQP::Client::Connection

• AMQP::Client::Connection
• Reference
• Object

Defined in:

amqp-client/connection.cr
amqp-client/errors.cr

Constant Summary

LOG = AMQP::Client::LOG.for(self)

Constructors

• .new(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, channel_max : UInt16, frame_max : UInt32, heartbeat : UInt16)

Class Method Summary

• .start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, user, password, vhost, channel_max, frame_max, heartbeat, name : String?)

Instance Method Summary

• #channel(id : Int? = nil)
• #channel(&blk : Channel -> _)
• #channel_max : UInt16
• #close(msg = "", no_wait = false)
• #closed? : Bool
• #closing_frame : Frame::Connection::Close?
• #frame_max : UInt32
• #on_close(&blk : UInt16, String -> )
• #unsafe_write(frame : Frame)
• #with_lock(&blk : self -> _)
• #write(frame : Frame)

Constructor Detail

Class Method Detail

Instance Method Detail