MakoIoT.Device.Services.Mqtt 1.0.104.13410

Mako-IoT.Device.Services.Mqtt

ICommunicationService implementation with MQTT as transport layer. Uses M2MQTT library.

Usage

Add MQTT and configuration in DeviceBuilder

DeviceBuilder.Create()
 .AddWiFi()
 .AddMqtt()
 .AddConfiguration(cfg =>
 {
 cfg.WriteDefault(WiFiConfig.SectionName, new WiFiConfig
 {
 Ssid = "",
 Password = ""
 });
 cfg.WriteDefault(MqttConfig.SectionName, new MqttConfig
 {
 BrokerAddress = "test.mosquitto.org",
 Port = 8883,
 UseTLS = true,
 CACert = "...", //broker's TLS certificate
 ClientId = "device1",
 TopicPrefix = "mako-iot-test", //prefix for pub-sub topics
 PublishQoS = 1, //QoS for published messages (0-2)
 PublishRetain = false //retain flag for published messages
 });
 })
 .Build()
 .Start();

ICommunicationService

See example in MessageBus class.