class

AMQP::Client::Connection

Inherits Reference < Object

Class methods

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

Source

Instance methods

blocked?
Source
channel(id : Int | Nil = nil)

Opens a channel

Source
channel
Source
channel_max
Source
close(reason = "", no_wait = false)

Close the connection the server.

The reason might be logged by the server

Source
closed?
Source
closing_frame
Source
frame_max
Source
on_blocked

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

Source
on_close

Callback called when the server closes the Connection gracefully via an AMQP Connection.Close method frame.

Source
on_disconnect

Callback called when the Connection is lost at the network layer — i.e. the read loop encountered IO::Error or OpenSSL::Error without a preceding AMQP Connection.Close frame.

Source
on_unblocked

Callback for when the server is unblocked again

Source
update_secret(secret : String, reason : String) : Nil
Source

Nested types