MattzoMQTTSubscriber.h

Go to the documentation of this file.

#pragma once
 
#include <Arduino.h>
 
// PubSubClient library by Nick O'Leary
// Install via the built-in Library Manager of the Arduino IDE
// Tested with Version V2.8.0
#include <PubSubClient.h>
 
// WiFi library for ESP-32
#include "MCMQTTConfiguration.h"
#include <Ethernet.h>
#include <EthernetUdp.h>
#include <WiFi.h>
 
// MQTT task priority.
#define MQTT_TASK_PRIORITY 2
 
// MQTT handle message task core ID.
#define MQTT_HANDLE_MESSAGE_TASK_COREID 1
 
// The size of the MQTT task stack specified as the number of bytes.
#define MQTT_TASK_STACK_DEPTH 3072
 
// Number of message received the MQTT queue can hold before we start dropping them.
// Please note the more messages allowed to be queued, the more (heap) memory we consume.
#define MQTT_INCOMING_QUEUE_LENGTH 100
 
// Number of message to send the MQTT queue can hold before we start dropping them.
// Please note the more messages allowed to be queued, the more (heap) memory we consume.
#define MQTT_OUTGOING_QUEUE_LENGTH 1000
 
#define MQTT_UNINITIALIZED -10
 
extern WiFiClient wifiSubscriberClient;
extern PubSubClient mqttSubscriberClient;
 
class MattzoMQTTSubscriber
{
  public:
    // Public static members
 
    // Incoming MQTT message queue.
    static QueueHandle_t IncomingQueue;
 
    static int ReconnectDelayInMilliseconds;
 
    static int HandleMessageDelayInMilliseconds;
 
    static uint8_t TaskPriority;
 
    static int8_t CoreID;
 
    static uint32_t StackDepth;
 
    static uint16_t MaxBufferSize;
 
    // Methods
 
    static void Setup(MCMQTTConfiguration *config, void (*MQTThandler)(const char *message));
 
    // Returns the current MQTT connection status.
    static int GetStatus();
 
    // All code that should be handled in the Loop
    static void Loop();
 
    //pointer to hanler function
    static void (*handler)(const char *message);
  private:
    static MCMQTTConfiguration *_config;
    static char _subscriberName[60];
    static bool _setupCompleted;
 
    // Time of the last sent ping.
    static unsigned long lastPing;
 
    // Callback used to put received message on a queue.
    static void mqttCallback(char *topic, byte *payload, unsigned int length);
 
    static void sendMessage(char *topic, const char *message);
 
    static void reconnect();
 
    static void taskLoop(void *parm);
};