MBED MQTT Lighting Endpoint for NXP LPC1768+AppBoard

Dependencies:   C12832_lcd EthernetInterface StatusReporter LM75B MQTT-ansond endpoint_core endpoint_mqtt mbed-rtos mbed

Files at this revision

API Documentation at this revision

Comitter:
ansond
Date:
Fri Mar 21 05:23:52 2014 +0000
Parent:
159:c826229c1eec
Child:
161:eea2bbfbb387
Commit message:
updates

Changed in this revision

Definitions.h Show annotated file Show diff for this revision Revisions of this file
MQTT.lib Show annotated file Show diff for this revision Revisions of this file
MQTTTransport.cpp Show annotated file Show diff for this revision Revisions of this file
--- 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);