Diff: main.cpp

Revision:

18:44a64786f3ca

Parent:

17:d07286cd2088

Child:

19:8f5ab618edd0

--- a/main.cpp	Wed Feb 24 00:00:20 2016 +0000
+++ b/main.cpp	Sun Nov 12 11:36:25 2017 +0000
@@ -8,6 +8,7 @@
 #include "mbed.h"
  
 int arrivedcount = 0;
+
 DigitalOut sw1(D9);
 DigitalOut sw2(D10);
 DigitalOut sw3(D11);
@@ -68,7 +69,7 @@
     printf("IP Address : %s\r\n",ipstack.getEth().getIPAddress());
     MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack);
     
-    char* hostname = "192.168.1.213";
+    char* hostname = "222.98.173.239";
     printf("connect to %s\r\n",hostname);
     int port = 1883;
     
@@ -84,10 +85,10 @@
     
     MQTTPacket_connectData data = MQTTPacket_connectData_initializer;       
     data.MQTTVersion = 3;
-    sprintf(MQTTClientID,"WIZwiki-W7500-client-%d",rand()%1000);
+    sprintf(MQTTClientID,"WIZwiki-W7500-client-%d",rand()%10000);
     data.clientID.cstring = MQTTClientID;
-    data.username.cstring = "";
-    data.password.cstring = "";  
+    data.username.cstring = "wiznetacademy";
+    data.password.cstring = "wiznet1324";  
     
     if ((rc = client.connect(data)) != 0)
     {
@@ -97,7 +98,7 @@
     printf("MQTT connection is successful\r\n");
 
         
-    char *sw1 = "/wiznet/sw1";
+    char *sw1 = "light/control";
     if ((rc = client.subscribe(sw1, MQTT::QOS1, sw1_messageArrived)) != 0)
     {
         printf("rc from MQTT subscribe is %d\r\n", rc);
@@ -105,7 +106,7 @@
     }
     printf("Added subscription for sw1\r\n");
     
-    char *sw2 = "/wiznet/sw2";
+    char *sw2 = "boiler/control";
     if ((rc = client.subscribe(sw2, MQTT::QOS1, sw2_messageArrived)) != 0)
     {
         printf("rc from MQTT subscribe is %d\r\n", rc);
@@ -113,7 +114,7 @@
     }
     printf("Added subscription for sw2\r\n");
         
-    char *sw3 = "/wiznet/sw3";
+    char *sw3 = "radio/control";
     if ((rc = client.subscribe(sw3, MQTT::QOS1, sw3_messageArrived)) != 0)
     {
         printf("rc from MQTT subscribe is %d\r\n", rc);
@@ -121,35 +122,8 @@
     }
     printf("Added subscription for sw3\r\n");
 
-    MQTT::Message message;
-    char buf[100];
-    int error = 0;
-    float hum = 0.0f, temp = 0.0f;
-    char i = 0;
     while (true)
     {
-        if(i > 100) i = 0;
-        error = sensor.readData();
-        if (0 == error) {
-            hum = sensor.ReadHumidity();
-            temp = sensor.ReadTemperature(CELCIUS);
-        }
-        message.qos = MQTT::QOS1;
-        message.retained = false;
-        message.dup = false;
-        
-        sprintf(buf, "%3.1f", hum);
-        message.payload = (void*)buf;
-        message.payloadlen = strlen(buf);
-        rc = client.publish("/wiznet/humidity",message);
-        printf("publish humidity data %s\r\n",(char*)message.payload);
-        
-        sprintf(buf, "%3.1f", temp);
-        message.payload = (void*)buf;
-        message.payloadlen = strlen(buf);
-        rc = client.publish("/wiznet/temperature", message);
-        printf("publish temperature data %s\r\n",(char*)message.payload);
-        
         client.yield(5000);
     }
 }