Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Fork of HelloMQTT by
Revision 18:07a79d8f01c3, committed 2015-07-27
- Comitter:
- icraggs
- Date:
- Mon Jul 27 09:30:31 2015 +0000
- Parent:
- 17:0811bdbdd78a
- Child:
- 19:7f7aba7a4a8b
- Commit message:
- Make it easy to not use LCD screen, if you don't have one
Changed in this revision
| main.cpp | Show annotated file Show diff for this revision Revisions of this file |
--- a/main.cpp Mon Jul 27 09:16:08 2015 +0000
+++ b/main.cpp Mon Jul 27 09:30:31 2015 +0000
@@ -24,7 +24,11 @@
system libraries.
*/
+
+ // change this to 0 to output messages to serial instead of LCD
+#define USE_LCD 1
+#if USE_LCD
#include "C12832.h"
#if defined(TARGET_UBLOX_C027)
@@ -38,6 +42,10 @@
#include "K64F.h"
#endif
+#define printf lcd.cls();lcd.printf
+
+#endif
+
#define MQTTCLIENT_QOS2 1
#include "MQTTEthernet.h"
@@ -52,8 +60,6 @@
printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id);
printf("Payload %.*s\n", message.payloadlen, (char*)message.payload);
++arrivedcount;
- lcd.cls();
- lcd.puts((char*)message.payload);
}
@@ -63,21 +69,16 @@
float version = 0.5;
char* topic = "mbed-sample";
- lcd.cls();
- lcd.printf("HelloMQTT: version is %f\n", version);
+ printf("HelloMQTT: version is %f\n", version);
MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack);
char* hostname = "m2m.eclipse.org";
int port = 1883;
- lcd.cls();
- lcd.printf("Connecting to %s:%d\n", hostname, port);
+ printf("Connecting to %s:%d\n", hostname, port);
int rc = ipstack.connect(hostname, port);
if (rc != 0)
- {
- lcd.cls();
- lcd.printf("rc from TCP connect is %d\n", rc);
- }
+ printf("rc from TCP connect is %d\n", rc);
MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
data.MQTTVersion = 3;
@@ -85,16 +86,10 @@
data.username.cstring = "testuser";
data.password.cstring = "testpassword";
if ((rc = client.connect(data)) != 0)
- {
- lcd.cls();
- lcd.printf("rc from MQTT connect is %d\n", rc);
- }
+ printf("rc from MQTT connect is %d\n", rc);
if ((rc = client.subscribe(topic, MQTT::QOS1, messageArrived)) != 0)
- {
- lcd.cls();
- lcd.printf("rc from MQTT subscribe is %d\n", rc);
- }
+ printf("rc from MQTT subscribe is %d\n", rc);
MQTT::Message message;
@@ -129,19 +124,18 @@
if ((rc = client.unsubscribe(topic)) != 0)
{
lcd.cls();
- lcd.printf("rc from unsubscribe was %d\n", rc);
+ printf("rc from unsubscribe was %d\n", rc);
}
if ((rc = client.disconnect()) != 0)
{
lcd.cls();
- lcd.printf("rc from disconnect was %d\n", rc);
+ printf("rc from disconnect was %d\n", rc);
}
ipstack.disconnect();
- lcd.cls();
- lcd.printf("Version %.2f: finish %d msgs\n", version, arrivedcount);
+ printf("Version %.2f: finish %d msgs\n", version, arrivedcount);
return 0;
}
