class
MQTT::Client::Connection
- MQTT::Client::Connection
- Reference
- Object
Defined in:
mqtt-client/connection.crConstant Summary
-
Log =
::Log.for(self)
Constructors
- .new(host : String, port = 1883, tls = false, client_id = "", clean_session = true, user : String | Nil = nil, password : String | Nil = nil, will : Message | Nil = nil, keepalive : Int = 60_u16, autoack = true, sock_opts = SocketOptions.new, on_message : Proc(ReceivedMessage, Nil) | Nil = nil)
- .new(socket : IO, client_id : String = "", clean_session : Bool = true, user : String | Nil = nil, password : String | Nil = nil, will : Message | Nil = nil, keepalive : UInt16 = 60_u16, autoack : Bool = false, on_message : Proc(ReceivedMessage, Nil) | Nil = nil)
Instance Method Summary
- #close
- #connected? : Bool
- #disconnect
- #on_message(&blk : Proc(ReceivedMessage, Nil))
- #on_message=(blk : Proc(ReceivedMessage, Nil) | Nil)
- #ping
- #puback(packet_id : UInt16)
- #publish(topic : String, body, qos : Int = 0_u8, retain = false, dup = false)
- #publish(msg : Message)
- #pubrec(packet_id : UInt16)
- #subscribe(topic : String, qos : UInt8 = 0_u8)
- #subscribe(topics : Enumerable(Tuple(String, UInt8)))
- #subscribe(*topics : Tuple(String, UInt8))
- #unsubscribe(*topics : String)
Constructor Detail
def self.new(host : String, port = 1883, tls = false, client_id = "", clean_session = true, user : String | Nil = nil, password : String | Nil = nil, will : Message | Nil = nil, keepalive : Int = 60_u16, autoack = true, sock_opts = SocketOptions.new, on_message : Proc(ReceivedMessage, Nil) | Nil = nil)
#
def self.new(socket : IO, client_id : String = "", clean_session : Bool = true, user : String | Nil = nil, password : String | Nil = nil, will : Message | Nil = nil, keepalive : UInt16 = 60_u16, autoack : Bool = false, on_message : Proc(ReceivedMessage, Nil) | Nil = nil)
#