MqttClient

MQTT Client implementation

class MqttClient {

import std.array : Appender;;

this(Settings settings);

void connect();

void disconnect();

bool connected [@property getter];

void publish(string topic, T payload, QoSLevel qos, bool retain);

void subscribe(string[] topics, QoSLevel qos);

void onConnAck(ConnAck packet);

void onPingResp(PingResp packet);

void onPubAck(PubAck packet);

void onPubRec(PubRec packet);

void onPubRel(PubRel packet);

void onPubComp(PubComp packet);

void onPublish(Publish packet);

void onSubAck(SubAck packet);

void onUnsubAck(UnsubAck packet);

void onDisconnect();

}

Constructors

this this(Settings settings): Undocumented in source.

Members

Functions

connect void connect(): Connects to the specified broker and sends it the Connect packet
disconnect void disconnect(): Sends Disconnect packet to the broker and closes the underlying connection
onConnAck void onConnAck(ConnAck packet): Undocumented in source. Be warned that the author may not have intended to support it.
onDisconnect void onDisconnect(): Undocumented in source. Be warned that the author may not have intended to support it.
onPingResp void onPingResp(PingResp packet): Undocumented in source. Be warned that the author may not have intended to support it.
onPubAck void onPubAck(PubAck packet): Undocumented in source. Be warned that the author may not have intended to support it.
onPubComp void onPubComp(PubComp packet): Undocumented in source. Be warned that the author may not have intended to support it.
onPubRec void onPubRec(PubRec packet): Undocumented in source. Be warned that the author may not have intended to support it.
onPubRel void onPubRel(PubRel packet): Undocumented in source. Be warned that the author may not have intended to support it.
onPublish void onPublish(Publish packet): Undocumented in source. Be warned that the author may not have intended to support it.
onSubAck void onSubAck(SubAck packet): Undocumented in source. Be warned that the author may not have intended to support it.
onUnsubAck void onUnsubAck(UnsubAck packet): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(string topic, T payload, QoSLevel qos, bool retain): Publishes the message on the specified topic
subscribe void subscribe(string[] topics, QoSLevel qos): Subscribes to the specified topics

Properties

connected bool connected [@property getter]: Return true, if client is in a connected state

Meta

Source

See Implementation

mqttd client aliases

SessionContainer

classes

MqttClient

enums

PacketState

manifest constants

structs