class LavinMQ::Client
- LavinMQ::Client
- Reference
- Object
Included Modules
Defined in:
lavinmq/client/channel.crlavinmq/client/channel/consumer.cr
lavinmq/client/channel/stream_consumer.cr
lavinmq/client/client.cr
Constant Summary
-
DEFAULT_EX =
"amq.default"
Constructors
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)
- #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 : Log
- #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
Instance methods inherited from module LavinMQ::SortableJSON
details_tuple
details_tuple,
to_json(json : JSON::Builder)
to_json
Constructor Detail
def self.new(socket : IO, connection_info : ConnectionInfo, vhost : VHost, user : User, tune_ok, start_ok)
#