mqtt esp test
Dependencies: ESP8266Interface MQTT mbed-rtos mbed-src
Fork of ESP8266_MQTT_HelloWorld by
Diff: main.cpp
- Revision:
- 18:76d0899bc3ce
- Parent:
- 17:92a64d43ee61
- Child:
- 19:1174b87e2111
--- a/main.cpp Fri Jun 05 15:15:24 2015 +0000 +++ b/main.cpp Tue Jun 09 17:57:43 2015 +0000 @@ -30,19 +30,20 @@ int arrivedcount = 0; - -void messageArrived(MQTT::MessageData& md) +// callback for subscribe topic +void subscribeCallback(MQTT::MessageData& md) { MQTT::Message &message = md.message; - printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id); + printf("Message received: 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; } +// main function that sets up the subscription and makes a couple publishes int main(int argc, char* argv[]) { printf("Starting\n"); - MQTTESP8266 ipstack(D1, D0, D10, "ssid", "password"); + MQTTESP8266 ipstack(D1, D0, D10, "demossid","passphrase"); // change to match your wifi access point float version = 0.47; char* topic = "mbed-sample"; @@ -50,7 +51,7 @@ MQTT::Client<MQTTESP8266, Countdown> client = MQTT::Client<MQTTESP8266, Countdown>(ipstack); - char* hostname = "192.168.1.20"; + char* hostname = "85.119.83.194"; // test.mosquitto.org int port = 1883; int rc = ipstack.connect(hostname, port); if (rc != 0) @@ -58,14 +59,14 @@ MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 3; - data.clientID.cstring = "mbed-sample"; + data.clientID.cstring = "mbed-clientID"; data.username.cstring = "testuser"; data.password.cstring = "testpassword"; if ((rc = client.connect(data)) != 0) printf("rc from MQTT connect is %d\n", rc); - if ((rc = client.subscribe("mbed-sample", MQTT::QOS1, messageArrived)) != 0) - printf("rc from MQTT subscribe is %d\n", rc); + if ((rc = client.subscribe(topic, MQTT::QOS1, subscribeCallback)) != 0) + printf("Recv'd from MQTT subscribe is %d\n", rc); MQTT::Message message;