X-Git-Url: http://git.piffa.net/web?a=blobdiff_plain;f=iot%2Fmqtt_publish%2Fmqtt_publish.ino;fp=iot%2Fmqtt_publish%2Fmqtt_publish.ino;h=dc03d004dfd0fce80bd42c47e3d95b14f18bf1c4;hb=b4d82b0010d746f1a0f0b4da698b26d217f1ab1f;hp=0000000000000000000000000000000000000000;hpb=c5a3dc4a9cc7eea224814fee4b00575e726105fa;p=sketchbook_andrea

diff --git a/iot/mqtt_publish/mqtt_publish.ino b/iot/mqtt_publish/mqtt_publish.ino
new file mode 100644
index 0000000..dc03d00
--- /dev/null
+++ b/iot/mqtt_publish/mqtt_publish.ino
@@ -0,0 +1,39 @@
+#include <ESP8266WiFi.h>
+void connection() ;
+
+#include <PubSubClient.h>
+const char* mqtt_server = "chrome";
+const char* input = "inTopic" ;
+const char* output = "outTopic" ;
+
+WiFiClient espClient; // WiFi connection obj
+PubSubClient client(espClient); // MQTT client obj
+
+const byte ledPin = 2; // GPIO2 on LoLin Nodemcu
+
+void setup() {
+  Serial.begin(115200);
+  delay(10);
+
+  pinMode(ledPin, OUTPUT);
+  digitalWrite(ledPin, HIGH); // OnBoard LED is inverted
+
+  connection();
+  client.setServer(mqtt_server, 1883);  
+}
+
+void loop() {
+  
+if (!client.connected()) { // Keep MQTT connection on
+    reconnect();
+  }
+
+
+char msg[50];
+ snprintf (msg, 75, "Test message @millis:  %ld", millis());
+client.publish(output, msg);
+delay(1000);
+
+client.loop();
+}
+