class AMQP::Client::Connection

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

Defined in:

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

Class Method Summary

• .start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, user, password, vhost, channel_max, frame_max, heartbeat, connection_information, name = File.basename(PROGRAM_NAME))

  Connection negotiation

Instance Method Summary

• #blocked? : Bool
• #channel(id : Int | Nil = nil)

  Opens a channel

• #channel(& : 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_blocked(&blk : String -> )

  Callback called when server is blocked, first argument is the reason from the server

• #on_close(&blk : UInt16, String -> )

  Callback that's called if the Connection is closed by the server

• #on_unblocked(&blk : -> )

  Callback for when the server is unblocked again

• #update_secret(secret : String, reason : String) : Nil

Class Method Detail

Instance Method Detail