class
LavinMQ::MQTT::Client
- LavinMQ::MQTT::Client
- LavinMQ::Client
- Reference
- Object
Included Modules
Defined in:
lavinmq/mqtt/client.crConstant Summary
-
Log =
LavinMQ::Log.for("mqtt.client")
Constructors
Instance Method Summary
- #channels : Hash(UInt16, LavinMQ::Client::Channel)
- #clean_session? : Bool
- #client_id : String
- #client_name
-
#close(reason = "")
should only be used when server needs to froce close client
- #connection_info : LavinMQ::ConnectionInfo
-
#current_stats_details
Like stats_details but without log
- #details_tuple
- #force_close
- #log : LavinMQ::Logger
- #name : String
- #read_and_handle_packet
- #receive_pingreq(packet : MQTT::PingReq)
- #recieve_puback(packet : MQTT::PubAck)
- #recieve_publish(packet : MQTT::Publish)
- #recieve_subscribe(packet : MQTT::Subscribe)
- #recieve_unsubscribe(packet : MQTT::Unsubscribe)
- #recv_oct_count : UInt64
- #search_match?(value : String) : Bool
- #search_match?(value : Regex) : Bool
- #send(packet)
- #send_oct_count : UInt64
- #socket : IO
- #state
- #stats_details
- #update_rates : Nil
- #user : LavinMQ::User
- #vhost
Instance methods inherited from module LavinMQ::SortableJSON
details_tuple
details_tuple,
search_match?(value : String)search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json
Macros inherited from module LavinMQ::Stats
rate_stats(stats_keys, log_keys = [] of ::String)
rate_stats
Instance methods inherited from module LavinMQ::SortableJSON
details_tuple
details_tuple,
search_match?(value : String)search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json
Constructor Detail
def self.new(socket : ::IO, connection_info : ConnectionInfo, user : User, broker : MQTT::Broker, client_id : String, clean_session : Bool = false, keepalive : UInt16 = 30, will : MQTT::Will | Nil = nil)
#