Joerg Wende
Sample test program for the MQTT PubSubClient library
Dependencies: C12832_lcd EthernetInterface MQTT mbed-rtos mbed
Revision 0:3f9dd63f4f98, committed 2013-05-26
- Comitter:
- jwende
- Date:
- Sun May 26 16:52:40 2013 +0000
- Child:
- 1:5570162c5994
- Commit message:
- Sample client implementation for for MQTT PubSubClient library
Changed in this revision
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/C12832_lcd.lib Sun May 26 16:52:40 2013 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/dreschpe/code/C12832_lcd/#468cdccff7af
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/EthernetInterface.lib Sun May 26 16:52:40 2013 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/mbed_official/code/EthernetInterface/#52d857c9e3ba
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/MQTT.lib Sun May 26 16:52:40 2013 +0000 @@ -0,0 +1,1 @@ +MQTT#ca855d29545b
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp Sun May 26 16:52:40 2013 +0000
@@ -0,0 +1,56 @@
+#include "mbed.h"
+#include "EthernetInterface.h"
+#include "C12832_lcd.h"
+#include "PubSubClient.h"
+
+C12832_LCD lcd;
+Serial pc(USBTX, USBRX);
+
+char* serverIpAddr = "192.168.2.111"; /*Sever ip address*/
+int port = 1883; /*Sever Port*/
+void callback(char* topic, char* payload, unsigned int len); /*Callback function prototype*/
+PubSubClient mqtt(serverIpAddr, port, callback);
+EthernetInterface eth;
+
+void callback(char* topic, char* payload, unsigned int len)
+{
+ lcd.printf("Topic: %s\r\n", topic);
+ lcd.printf("Payload: %s\r\n\r\n", payload);
+ //Send incoming payloads back to topic "/mbed".
+ mqtt.publish("mbed", payload, len);
+}
+
+int main() {
+
+ eth.init(); //Use DHCP
+ eth.connect();
+ lcd.cls();
+ lcd.locate(0,3);
+ pc.printf("IP Address is %s\n", eth.getIPAddress());
+
+ pc.printf("MQTTClient Tester");
+
+
+ char clientID[] = "mbed"; /*Client nanme show for MQTT server*/
+ char pub_topic[] = "mbed"; /*Publish to topic : "/mbed" */
+ char sub_topic[] = "mirror"; /*Subscribe to topic : "/mirror" */
+
+ if(!mqtt.connect(clientID)){
+ pc.printf("\r\nConnect to server failed ..\r\n");
+ return -1;
+ }
+
+ pc.printf("\r\nConnect to server sucessed ..\r\n");
+
+ mqtt.publish(pub_topic, "Hello here is mbed...");
+ mqtt.subscribe(sub_topic);
+
+
+ pc.printf("#### End of the test.. ####");
+
+ //eth.disconnect();
+
+ while(1) {
+ mqtt.loop();
+ }
+}
\ No newline at end of file
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mbed-rtos.lib Sun May 26 16:52:40 2013 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/mbed_official/code/mbed-rtos/#db1fc233faa9
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mbed.bld Sun May 26 16:52:40 2013 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/mbed_official/code/mbed/builds/b3110cd2dd17 \ No newline at end of file