class

LavinMQ::AMQP::Client

Inherits LavinMQ::SortableJSON < LavinMQ::Stats < LavinMQ::Client < LavinMQ::SortableJSON < Reference < Object

Constants

DEFAULT_EX = "amq.default"
Log = LavinMQ::Log.for("amqp.client")

Constructors

new(socket : IO, connection_info : ConnectionInfo, vhost : VHost, user : Auth::BaseUser, tune_ok, start_ok)
Source

Instance methods

auth_mechanism
Source
channel?(id : UInt16) : Client::Channel | Nil
Source
channel_count
Source
channel_max
Source
channel_name_prefix
Source
channels
Source
client_name

Returns client provided connection name if set, else server generated name

Source
client_properties
Source
close(reason = nil, timeout : Time::Span = 5.seconds, force_close_timeout : Time::Span | Nil = nil)

timeout applies to new socket writes, not to one already blocked on a client that doesn't read. force_close_timeout shuts the socket down if the Close frame isn't confirmed by then, which aborts such a write.

Source
closed?
Source
connection_details
Source
connection_info
Source
current_stats_details

Like stats_details but without log

Source
deliver(frame, msg, flush = true)
Source
details_tuple
Source
each_channel
Source
exclusive_queue_deleted(q : Queue) : Nil

Called by Queue#delete on the queue's exclusive owner

Source
flush
Source
force_close
Source
heartbeat_timeout
Source
log
Source
max_frame_size
Source
name
Source
queue_exclusive_to_other_client?(q)
Source
recv_oct_count
Source
search_match?(value : String) : Bool
Source
search_match?(value : Regex) : Bool
Source
send(frame : AMQP::Frame, channel_is_open : Bool | Nil = nil) : Bool
Source
send_access_refused(frame, text)
Source
send_frame_error(message = nil)
Source
send_internal_error(message)
Source
send_internal_queue_refused(frame, name)
Source
send_not_found(frame, text = "")
Source
send_not_implemented(ex : AMQ::Protocol::Error::NotImplemented)
Source
send_not_implemented(frame, text = nil)
Source
send_oct_count
Source
send_passive_not_found(frame, text = "")
Source
send_precondition_failed(frame, text)
Source
send_resource_error(frame, message)
Source
send_resource_locked(frame, text)
Source
state
Source
stats_details
Source
to_json(json : JSON::Builder)
Source
update_rates
Source
user
Source
vhost
Source