IMQTT_Client.h

Go to the documentation of this file.

#ifndef IMQTT_Client_h
#define IMQTT_Client_h
 
// Local include.
#include "Callback.h"
#include "DefaultLogger.h"
#include "MQTT_Connection_State.h"
#include "MQTT_Connection_Error.h"
 
// Library include.
#if THINGSBOARD_ENABLE_STREAM_UTILS
#include <Print.h>
#endif // THINGSBOARD_ENABLE_STREAM_UTILS
 
 
#if THINGSBOARD_ENABLE_STREAM_UTILS
class IMQTT_Client : public Print {
#else
class IMQTT_Client {
#endif // THINGSBOARD_ENABLE_STREAM_UTILS
  public:
    virtual ~IMQTT_Client() {}
 
    virtual void set_data_callback(Callback<void, char *, uint8_t *, unsigned int>::function callback) = 0;
 
    virtual void set_connect_callback(Callback<void>::function callback) = 0;
 
    virtual bool set_buffer_size(uint16_t receive_buffer_size, uint16_t send_buffer_size) = 0;
 
    virtual uint16_t get_receive_buffer_size() = 0;
 
    virtual uint16_t get_send_buffer_size() = 0;
 
    virtual void set_server(char const * domain, uint16_t port) = 0;
 
    virtual bool connect(char const * client_id, char const * user_name, char const * password) = 0;
 
    virtual void disconnect() = 0;
 
    virtual bool loop() = 0;
 
    virtual bool publish(char const * topic, uint8_t const * payload, size_t const & length) = 0;
 
    virtual bool subscribe(char const * topic) = 0;
  
    virtual bool unsubscribe(char const * topic) = 0;
 
    virtual bool connected() = 0;
 
    virtual MQTT_Connection_State get_connection_state() const = 0;
 
    virtual MQTT_Connection_Error get_last_connection_error() const = 0;
 
    virtual void subscribe_connection_state_changed_callback(Callback<void, MQTT_Connection_State, MQTT_Connection_Error>::function callback) = 0;
 
#if THINGSBOARD_ENABLE_STREAM_UTILS
 
    virtual bool begin_publish(char const * topic, size_t const & length) = 0;
 
    virtual bool end_publish() = 0;
 
    //----------------------------------------------------------------------------
    // Print interface
    //----------------------------------------------------------------------------
 
    virtual size_t write(uint8_t payload_byte) = 0;
 
    virtual size_t write(uint8_t const * buffer, size_t const & size) = 0;
 
#endif // THINGSBOARD_ENABLE_STREAM_UTILS
};
 
#endif // IMQTT_Client_h