class

MQTT::Transport::TCP

Inherits MQTT::Transport / Reference / Object

Constructors

new(host : String, port : Int32 = MQTT::DEFAULT_PORT, tls_context : OpenSSL::SSL::Context::Client | Nil = nil, dns_timeout : Int32 = 10, connect_timeout : Int32 = 10, read_timeout : Int32 | Nil = nil, write_timeout : Int32 | Nil = nil)

NOTE:: the socket is not opened here. Connecting is deferred to start, which the client calls once it is ready to consume data

Source

Instance methods

close!
Source
closed?
Source
host
Source
port
Source
send(message) : Nil
Source
start

Begins consuming data from the remote host. Called by the client once its callbacks have been configured so that no data can arrive before there is something able to process it

Source