#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;
}