MqttTransport

class MqttTransport : Transport {

this(MosquittoClient.Settings sets);

void init(string name);

void connect();

bool connected();

void reconnect();

void publish(string topic, const(ubyte)[] data, QoS qos);

void subscribe(string topic, void delegate(string, const(ubyte)[]) dlg, QoS qos);

}

Constructors

this this(MosquittoClient.Settings sets)

Members

Functions

connect void connect()
connected bool connected()
init void init(string name)
loop void loop()
publish void publish(string topic, const(ubyte)[] data, QoS qos)
reconnect void reconnect()
subscribe void subscribe(string topic, void delegate(string, const(ubyte)[]) dlg, QoS qos)

Inherited Members

From Transport

init void init(string name)
connect void connect()
connected bool connected()
publish void publish(string topic, const(ubyte)[] data, QoS qos)
subscribe void subscribe(string topic, void delegate(string, const(ubyte)[]) dlg, QoS qos)

Meta

Source

See Implementation

drmi mqtt transport classes

MqttTransport