class LavinMQ::MQTT::Client

• LavinMQ::MQTT::Client
• LavinMQ::Client
• Reference
• Object

Included Modules

• LavinMQ::SortableJSON
• LavinMQ::Stats

Defined in:

Constant Summary

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

Constructors

• .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)

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
• #search_match?(value : String) : Bool
• #search_match?(value : Regex) : Bool
• #send(packet)
• #send_oct_count
• #socket : IO
• #state
• #stats_details
• #update_rates : Nil
• #user : LavinMQ::User
• #vhost

Constructor Detail

Instance Method Detail