MqttCrystal::Client

DEFAULT_SOCKET_ARGS = { family: Socket::Family::INET, type: Socket::Type::STREAM, protocol: Socket::Protocol::TCP, blocking: false, }

new(host : String = "127.0.0.1", port : UInt16 = 1883_u16, username : String | Nil = nil, password : String | Nil = nil, url : String | Nil = nil, id : String | Nil = nil, keep_alive : UInt16 = 15_u16, auto_reconnect : Bool = true, tls : Bool = false)

host=(host : String)

id=(id : String)

password=(password : Nil | String)

port=(port : UInt16)

publish(topic : String, payload : String, qos : UInt8 = 1_u8, retain : Bool = false)

subscribe(topic : String) : self

subscribe(topics : Enumerable(String)) : self

subscribed?(topic)

username=(username : Nil | String)