version 1.1, 2012/01/25 10:34:14
|
version 1.2, 2012/01/27 15:05:38
|
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; |
|
} |