class LavinMQ::AMQP::Client

• LavinMQ::AMQP::Client
• LavinMQ::Client
• Reference
• Object

Included Modules

• LavinMQ::SortableJSON
• LavinMQ::Stats

Defined in:

lavinmq/amqp/client.cr

Constant Summary

DEFAULT_EX = "amq.default"

Log = LavinMQ::Log.for("amqp.client")

Constructors

• .new(socket : IO, connection_info : ConnectionInfo, vhost : VHost, user : User, tune_ok, start_ok)

Instance Method Summary

• #auth_mechanism : String
• #channel_max : UInt16
• #channel_name_prefix
• #channels : Hash(UInt16, LavinMQ::Client::Channel)
• #client_name

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

• #client_properties : AMQP::Table
• #close(reason = nil, timeout : Time::Span = 5.seconds)
• #close_channel(frame : AMQ::Protocol::Frame, code, text)
• #close_connection(frame : AMQ::Protocol::Frame | Nil, code, text)
• #closed?
• #connection_details
• #current_stats_details

  Like stats_details but without log

• #deliver(frame, msg)
• #details_tuple
• #force_close
• #heartbeat_timeout : UInt16
• #log : LavinMQ::Logger
• #max_frame_size : UInt32
• #name : String
• #queue_exclusive_to_other_client?(q)
• #recv_oct_count : UInt64
• #remote_address : Socket::IPAddress
• #send(frame : AMQP::Frame, channel_is_open : Bool | Nil = nil) : Bool
• #send_access_refused(frame, text)
• #send_frame_error(message = nil)
• #send_internal_error(message)
• #send_not_found(frame, text = "")
• #send_not_implemented(ex : AMQ::Protocol::Error::NotImplemented)
• #send_not_implemented(frame, text = nil)
• #send_oct_count : UInt64
• #send_precondition_failed(frame, text)
• #send_resource_locked(frame, text)
• #state
• #stats_details
• #update_rates : Nil
• #user : LavinMQ::User
• #vhost : LavinMQ::VHost

Constructor Detail

Instance Method Detail