MQTT 0.4.30 update to SYSTEM_THREAD(ENABLED) impl

Developer Tools
1

Hi there :wave:

Now I update MQTT community library version 0.4.30 SYSTEM_THREAD(ENABLED) impl.

Here is sample app( threadtest )

#include "MQTT.h"

SYSTEM_THREAD(ENABLED);
void callback(char* topic, byte* payload, unsigned int length);

/**
 * if want to use IP address,
 * byte server[] = { XXX,XXX,XXX,XXX };
 * MQTT client(server, 1883, callback);
 * want to use domain name,
 * exp) iot.eclipse.org is Eclipse Open MQTT Broker: https://iot.eclipse.org/getting-started
 * MQTT client("mqtt.eclipse.org", 1883, callback, true);
 *      4th parameter : bool thread(default false.)
 *      SYSTEM_THREAD(ENABLED) settings : thread is true.
 **/
MQTT client("sample.com", 1883, callback, true);

// recieve message
void callback(char* topic, byte* payload, unsigned int length) {
    char p[length + 1];
    memcpy(p, payload, length);
    p[length] = NULL;

    if (!strcmp(p, "RED"))
        RGB.color(255, 0, 0);
    else if (!strcmp(p, "GREEN"))
        RGB.color(0, 255, 0);
    else if (!strcmp(p, "BLUE"))
        RGB.color(0, 0, 255);
    else
        RGB.color(255, 255, 255);
    delay(1000);
}


void setup() {
    WiFi.on();
    WiFi.setCredentials("ssid", "pass");
    WiFi.connect();
    waitUntil(WiFi.ready);
    while (WiFi.localIP() == IPAddress()) {
    	delay(10);
    }

    // set LED control
    RGB.control(true);

    // connect to the server
    client.connect("sparkclient");

    // publish/subscribe
    if (client.isConnected()) {
        client.publish("outTopic/message","hello world");
        client.subscribe("inTopic/message");
    }
}

void loop() {
    if (client.isConnected())
      client.loop();
    delay(100);
}

If find a bug or something diff, Iā€™m happy from your report/issue. This version test on my Argon/Photon firmware version 2.0.1.
And I will update MQTT-TLS to SYSTEM_THREAD(ENABLED) later.

Thank you.

4 Likes
2

This topic was automatically closed 182 days after the last reply. New replies are no longer allowed.