--- mqtt/src/mqttd_calls.c 2012/01/25 10:34:14 1.1 +++ mqtt/src/mqttd_calls.c 2012/01/25 10:34:14 1.1.2.1 @@ -0,0 +1,31 @@ +#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; +}