Merge pull request #33 from 256dpi/more-advanced-publish

More Advanced Publish

README.md

@@ -127,8 +127,11 @@ boolean publish(String topic, String payload);
 boolean publish(const char * topic, String payload);
 boolean publish(const char * topic, const char * payload);
 boolean publish(const char * topic, char * payload, unsigned int length);
+boolean publish(MQTTMessage * message)
 ```
 
+- The last function can be used to publish messages with more low level attributes like `retained`.
+
 Subscribe to a topic:
 
 ```c++

src/MQTTClient.cpp

@@ -87,6 +87,17 @@ boolean MQTTClient::publish(const char * topic, char * payload, unsigned int len
   return client->publish(topic, message) == MQTT::SUCCESS;
 }
 
+boolean MQTTClient::publish(MQTTMessage * message) {
+  MQTT::Message _message;
+  _message.qos = MQTT::QOS0;
+  _message.retained = message->retained;
+  _message.dup = false;
+  _message.payload = message->payload;
+  _message.payloadlen = message->length;
+
+  return client->publish(message->topic, _message) == MQTT::SUCCESS;
+}
+
 boolean MQTTClient::subscribe(String topic) {
   return this->subscribe(topic.c_str());
 }

src/MQTTClient.h

@@ -15,6 +15,13 @@
 #include "Network.h"
 #include "Timer.h"
 
+typedef struct {
+    char * topic;
+    char * payload;
+    unsigned int length;
+    boolean retained;
+} MQTTMessage;
+
 void messageReceived(String topic, String payload, char * bytes, unsigned int length);
 
 class MQTTClient {
@@ -37,6 +44,7 @@ class MQTTClient {
   boolean publish(const char * topic, String payload);
   boolean publish(const char * topic, const char * payload);
   boolean publish(const char * topic, char * payload, unsigned int length);
+  boolean publish(MQTTMessage * message);
   boolean subscribe(String topic);
   boolean subscribe(const char * topic);
   boolean unsubscribe(String topic);