class

Amqp::Connection

Inherits Reference < Object

Constants

Log = ::Log.for("amqp.connection")

Constructors

connect(config : Config) : Connection
Source

Instance methods

__force_broker_close_for_test(reply_code : UInt16 = 320_u16, reply_text : String = "CONNECTION_FORCED - broker forced connection closure") : Nil

Test-only hook: simulates a broker-sent connection.close after the connection is already Open. This exercises the recovery trigger classifier without requiring a broker process restart in the default spec suite.

Source
blocked?
Source
channel(id : UInt16) : Channel
Source
channel
Source
channel_max
Source
close(*, reply_code : UInt16 = 200_u16, reply_text : String = "OK") : Nil
Source
close_reason
Source
closed?
Source
config
Source
frame_max
Source
heartbeat
Source
on_blocked
Source
on_unblocked
Source
open_channel
Source
recovered_to_open?
Source
recovery_mode
Source
server_properties
Source
state_recovering?
Source
stats
Source
with_channel
Source

Nested types