Arduino Bootstrapper (v1.7.6)

Author: sblantipodi

src/BootstrapManager.cpp

@@ -87,13 +87,24 @@ void BootstrapManager::publish(const char *topic, JsonObject objectToSend, boole
 
 }
 
+/********************************** SUBSCRIBE TO A QUEUE TOPIC **********************************/
+void BootstrapManager::unsubscribe(const char *topic) {
+
+  queueManager.unsubscribe(topic);
+
+  if (DEBUG_QUEUE_MSG) {
+    Serial.print(F("TOPIC SUBSCRIBED [")); Serial.print(topic); Serial.println(F("] "));
+  }
+
+}
+
 /********************************** SUBSCRIBE TO A QUEUE TOPIC **********************************/
 void BootstrapManager::subscribe(const char *topic) {
-  
+
   queueManager.subscribe(topic);
-  
+
   if (DEBUG_QUEUE_MSG) {
-    Serial.print(F("TOPIC SUBSCRIBED [")); Serial.print(topic); Serial.println(F("] "));  
+    Serial.print(F("TOPIC SUBSCRIBED [")); Serial.print(topic); Serial.println(F("] "));
   }
 
 }

src/BootstrapManager.h

@@ -52,8 +52,9 @@ class BootstrapManager {
     void bootstrapLoop(void (*manageDisconnectionFunction)(), void (*manageQueueSubscription)(), void (*manageHardwareButton)()); // bootstrap loop()
     void publish(const char *topic, const char *payload, boolean retained); // send a message on the queue
     void publish(const char *topic, JsonObject objectToSend, boolean retained); // send a message on the queue
-    void subscribe(const char *topic); // subscribe to a queue topic    
-    void subscribe(const char *topic, uint8_t qos); // subscribe to a queue topic with qos 0 or 1   
+    void unsubscribe(const char *topic); // unsubscribe to a queue topic
+    void subscribe(const char *topic); // subscribe to a queue topic
+    void subscribe(const char *topic, uint8_t qos); // subscribe to a queue topic with qos 0 or 1
     JsonObject getJsonObject(); // return a new json object instance
     void nonBlokingBlink(); // blink default LED when sending data to the queue
     void getMicrocontrollerInfo(); // print or display microcontroller's info

src/QueueManager.cpp

@@ -125,6 +125,13 @@ void QueueManager::publish(const char *topic, const char *payload, boolean retai
 
 }
 
+/********************************** SUBSCRIBE TO A QUEUE TOPIC **********************************/
+void QueueManager::unsubscribe(const char *topic) {
+
+  mqttClient.unsubscribe(topic);
+
+}
+
 /********************************** SUBSCRIBE TO A QUEUE TOPIC **********************************/
 void QueueManager::subscribe(const char *topic) {
 

src/QueueManager.h

@@ -34,6 +34,7 @@ class QueueManager {
     void mqttReconnect(void (*manageDisconnections)(), void (*manageQueueSubscription)(), void (*manageHardwareButton)()); // manage reconnection on the queue
     void queueLoop(void (*manageDisconnections)(), void (*manageQueueSubscription)(), void (*manageHardwareButton)()); // manage queue loop 
     void publish(const char *topic, const char *payload, boolean retained); // send a message on the queue
+    void unsubscribe(const char *topic); // unsubscribe to a queue topic
     void subscribe(const char *topic); // subscribe to a queue topic
     void subscribe(const char *topic, uint8_t qos); // subscribe to a queue topic with qos 0 or 1