mqtt/src/mqttd_calls.c - diff

Return to mqttd_calls.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

-version 1.1, 2012/01/25 10:34:14
+version 1.1.2.1, 2012/01/25 10:34:14
- Line 0
+ Line 1
+ #include "global.h"
+ #include "mqttd.h"
+ #include "mqttd_calls.h"
+ int
+ Publish(struct tagSession *sess)
+ {
+         struct mqtthdr *hdr;
+         ioTRACE(2);
+         if (!sess)
+                 return -1;
+         hdr = (struct mqtthdr*) sess->sess_buf->msg_base;
+         switch (hdr->mqtt_msg.qos) {
+                 case MQTT_QOS_ONCE:
+                         break;
+                 case MQTT_QOS_ACK:
+                         break;
+                 case MQTT_QOS_EXACTLY:
+                         break;
+                 default:
+                         ioDEBUG(1, "Error:: Unknown QoS %d - rejected publishing request",
+                                         hdr->mqtt_msg.qos);
+                         return 0;
+         }
+         return 0;
+ }