added QoS option

feabhas · Feb 18, 2013 · 5a6ee36 · 5a6ee36
1 parent 463832f
commit 5a6ee36
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 3 deletions.
diff --git a/.DS_Store b/.DS_Store
diff --git a/build/.DS_Store b/build/.DS_Store
diff --git a/src/mqtt.c b/src/mqtt.c
@@ -199,7 +199,7 @@ mqtt_broker_handle_t * mqtt_connect(const char* client, const char * server_ip,
 
 
 
-int mqtt_subscribe(mqtt_broker_handle_t *broker, const char *topic)
+int mqtt_subscribe(mqtt_broker_handle_t *broker, const char *topic, QoS qos)
 {
 	if (!broker->connected) {
         return -1;

diff --git a/src/mqtt.h b/src/mqtt.h
@@ -35,12 +35,14 @@ POSSIBILITY OF SUCH DAMAGE.
 
 typedef struct mqtt_broker_handle mqtt_broker_handle_t;
 
+typedef enum {QoS0, QoS1, QoS2} QoS;
+
 mqtt_broker_handle_t * mqtt_connect(const char* client, const char * server_ip, uint32_t port);
 void mqtt_disconnect(mqtt_broker_handle_t *broker);
 
 int mqtt_publish(mqtt_broker_handle_t *broker, const char *topic, const char *msg);
 
-int mqtt_subscribe(mqtt_broker_handle_t *broker, const char *topic);
+int mqtt_subscribe(mqtt_broker_handle_t *broker, const char *topic, QoS qos);
 void mqtt_display_message(mqtt_broker_handle_t *broker, int (*print)(int));
 
 

diff --git a/submain/main.c b/submain/main.c
@@ -69,7 +69,7 @@ int main (int argc, char** argv)
         exit(1);
     }
 
-    int result = mqtt_subscribe(broker, topic);
+    int result = mqtt_subscribe(broker, topic, QoS0);
 
     if(result != 1) {
         puts("failed to Subscribe");