class AvalancheMQ::Client

• AvalancheMQ::Client
• Reference
• Object

Included Modules

• AvalancheMQ::SortableJSON
• AvalancheMQ::Stats

Defined in:

avalanchemq/client/channel.cr
avalanchemq/client/channel/consumer.cr
avalanchemq/client/client.cr

Constant Summary

DEFAULT_EX = "amq.default"

Constructors

• .new(socket : TCPSocket | OpenSSL::SSL::Socket | UNIXSocket, remote_address : Socket::IPAddress, local_address : Socket::IPAddress, vhost : VHost, user : User, events : Server::Event, tune_ok, start_ok)

Class Method Summary

• .start(socket, remote_address, local_address, vhosts, users, log, events)

Instance Method Summary

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

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

• #client_properties : AMQP::Table
• #close(reason = nil)
• #close_channel(frame, code, text)
• #close_connection(frame, code, text)
• #closed?
• #connection_details
• #deliver(frame, msg)
• #details_tuple
• #direct_reply_channel
• #direct_reply_consumer_tag : String | Nil
• #direct_reply_consumer_tag=(direct_reply_consumer_tag : Nil | String)
• #fd

  socket's file descriptor

• #force_close
• #heartbeat_timeout : UInt16
• #log : Logger
• #max_frame_size : UInt32
• #name : String
• #on_close(&blk : Client -> Nil)
• #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(frame)
• #send_oct_count : UInt64
• #send_precondition_failed(frame, text)
• #send_resource_locked(frame, text)
• #state
• #stats_details
• #update_rates
• #user : AvalancheMQ::User
• #vhost : AvalancheMQ::VHost

Constructor Detail

Class Method Detail

Instance Method Detail