MBED MQTT Lighting Endpoint for NXP LPC1768+AppBoard
Dependencies: C12832_lcd EthernetInterface StatusReporter LM75B MQTT-ansond endpoint_core endpoint_mqtt mbed-rtos mbed
Revision 160:3f373ec7ab3c, committed 2014-03-21
- Comitter:
- ansond
- Date:
- Fri Mar 21 05:23:52 2014 +0000
- Parent:
- 159:c826229c1eec
- Child:
- 161:eea2bbfbb387
- Commit message:
- updates
Changed in this revision
--- a/Definitions.h Fri Mar 21 04:34:08 2014 +0000 +++ b/Definitions.h Fri Mar 21 05:23:52 2014 +0000 @@ -110,7 +110,7 @@ #define MAX_MQTT_MESSAGE_LENGTH 128 // MQTT connect information -#define MQTT_HOSTNAME "iocana.bcu.ac.uk" // IOC MQTT Broker Host - iocana.bcu.ac.uk +#define MQTT_HOSTNAME "192.168.1.220" //"iocana.bcu.ac.uk" // IOC MQTT Broker Host - iocana.bcu.ac.uk #define MQTT_HOSTPORT 1883 // IOC MQTT Broker Port #define MQTT_ENDPOINT_ID "mbed%d" // IOC MQTT Endpoint ID template #define MQTT_MAXID_VALUE 99 // IOC MQTT Endpoint ID maximum integer value
--- a/MQTT.lib Fri Mar 21 04:34:08 2014 +0000 +++ b/MQTT.lib Fri Mar 21 05:23:52 2014 +0000 @@ -1,1 +1,1 @@ -http://mbed.org/users/ansond/code/MQTT-ansond/#3f246afce2c4 +http://mbed.org/users/ansond/code/MQTT-ansond/#3e73a2546953
--- a/MQTTTransport.cpp Fri Mar 21 04:34:08 2014 +0000 +++ b/MQTTTransport.cpp Fri Mar 21 05:23:52 2014 +0000 @@ -101,6 +101,7 @@ int length = 0; if (topic != NULL) length = strlen(topic); for(int i=length-1;i>=0 && !done;--i) if (topic[i] == '/') { topic[i] = ' ' ; done = true; } sscanf(topic,"%s%s",trash,ep); + //this->logger()->log("MQTT: Topic:[%s] trash:[%s] ep:[%s]",topic,trash,ep); if (strlen(ep) > 0) { if (strcmp(ep,MQTT_IOC_ALL_ENDPOINT) != 0) { // just insert the name and let the parser determine if its for us or not... @@ -153,9 +154,9 @@ else buffer[i] = '\0'; } } - if (count == 1) sscanf(buffer,"%s %s",message_type,message_verb); - if (count == 2) sscanf(buffer,"%s %s %s",message_type,message_verb,message_value); - if (count == 3) sscanf(buffer,"%s %s %s %s",message_type,message_verb,message_value,message_opt); + if (count == 1) sscanf(buffer,"%s%s",message_type,message_verb); + if (count == 2) sscanf(buffer,"%s%s%s",message_type,message_verb,message_value); + if (count == 3) sscanf(buffer,"%s%s%s%s",message_type,message_verb,message_value,message_opt); // DEBUG //this->logger()->log("Raw Payload: %s, length: %d",payload,payload_length);