MQTT on Wizwiki 7500 with DHT11 sensor example
Dependencies: DHT MQTT WIZnetInterface mbed-src
Fork of w7500-paho-mqtt by
Diff: main.cpp
- Revision:
- 12:4f0489448955
- Parent:
- 9:21574e058141
--- a/main.cpp Mon Jun 29 01:55:45 2015 +0000
+++ b/main.cpp Sat Oct 03 10:54:52 2015 +0000
@@ -2,10 +2,7 @@
#include "DHT.h"
#include "MQTTEthernet.h"
#include "MQTTClient.h"
-
#define ECHO_SERVER_PORT 7
-
-#include "mbed.h"
int arrivedcount = 0;
@@ -25,15 +22,14 @@
int main (void)
{
DHT sensor(D4, DHT11);
- AnalogIn ain(A1);
baud(115200);
printf("Wait a second...\r\n");
- char* topic = "hello/wiznet";
+ char* topic = "openhab/parents/command";
MQTTEthernet ipstack = MQTTEthernet();
MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack);
- char* hostname = "104.199.146.45";
+ char* hostname = "192.168.1.99";
int port = 1883;
int rc = ipstack.connect(hostname, port);
@@ -44,9 +40,7 @@
MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
data.MQTTVersion = 3;
- data.clientID.cstring = "WIZwiki-W7500";
- data.username.cstring = "testuser";
- data.password.cstring = "testpassword";
+ data.clientID.cstring = "parents";
if ((rc = client.connect(data)) != 0)
printf("rc from MQTT connect is %d\n", rc);
@@ -70,17 +64,14 @@
message.retained = false;
message.dup = false;
message.payload = (void*)buf;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish("wiznet/hum", message);
+ message.payloadlen = strlen(buf);
+ rc = client.publish("openhab/parents/humidity", message);
sprintf(buf, "%3.1f", temp);
message.payload = (void*)buf;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish("wiznet/temp", message);
- sprintf(buf, "%3.1f", ain.read()*100.0f);
- message.payload = (void*)buf;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish("wiznet/cds", message);
- client.yield(1000);
+ message.payloadlen = strlen(buf);
+ rc = client.publish("openhab/parents/temperature", message);
+
+ client.yield(60000);
}
}
