ELClientMqtt.h

Go to the documentation of this file.

 
// Copyright (c) 2016 by B. Runnels and T. von Eicken
 
#ifndef _EL_CLIENT_MQTT_H_
#define _EL_CLIENT_MQTT_H_
 
#include <stdint.h>
#include "FP.h"
#include "ELClient.h"
 
// Class to send and receive MQTT messages. This class should be used with a singleton object
// because the esp-link implementation currently only supports a single MQTT server, so there is
// no value in instantiating multiple ELClientMqtt objects (although it's possible).
// All the server settings are made in esp-link and esp-link takes care to automatically
// reconnect and retry if the connection is lost. This means that on the arduino side the only
// code that is necessary is to send and receive messsages.
class ELClientMqtt {
  public:
    // Initialize with an ELClient object
    ELClientMqtt(ELClient* elc);
 
    // setup transmits the set of callbacks to esp-link. It assumes that the desired callbacks
    // have previously been attached using something like mqtt->connectedCb.attach(myCallbackFun).
    // After setup is called either the connectedCb or the disconnectedCb is invoked to provide
    // information about the initial connection status.
    void setup(void);
 
    // callbacks that can be attached prior to calling setup
    FP<void, void*> connectedCb;    
    FP<void, void*> disconnectedCb; 
    FP<void, void*> publishedCb;    
    FP<void, void*> dataCb;         
    // subscribe to a topic, the default qos is 0. When messages are recevied for the topic the
    // data callback is invoked.
    void subscribe(const char* topic, uint8_t qos=0);
    void subscribe(const __FlashStringHelper* topic, uint8_t qos=0);
 
    // publish a message to a topic
    void publish(const char* topic, const uint8_t* data,
        const uint16_t len, uint8_t qos=0, uint8_t retain=0);
    void publish(const char* topic, const char* data,
        uint8_t qos=0, uint8_t retain=0);
    void publish(const __FlashStringHelper* topic, const __FlashStringHelper* data,
        const uint16_t len, uint8_t qos=0, uint8_t retain=0);
    void publish(const char* topic, const __FlashStringHelper* data,
        const uint16_t len, uint8_t qos=0, uint8_t retain=0);
    void publish(const __FlashStringHelper* topic, const uint8_t* data,
        const uint16_t len, uint8_t qos=0, uint8_t retain=0);
 
    // set a last-will topic & message
    void lwt(const char* topic, const char* message, uint8_t qos=0, uint8_t retain=0);
    void lwt(const __FlashStringHelper* topic, const __FlashStringHelper* message,
        uint8_t qos=0, uint8_t retain=0);
 
  private:
    ELClient* _elc; 
};
 
#endif // _EL_CLIENT_MQTT_H_