diff --git a/Arduino/BTCDieselHeater/src/WiFi/ABMqtt.cpp b/Arduino/BTCDieselHeater/src/WiFi/ABMqtt.cpp
new file mode 100644
index 0000000..52c0ed8
--- /dev/null
+++ b/Arduino/BTCDieselHeater/src/WiFi/ABMqtt.cpp
@@ -0,0 +1,27 @@
+// 
+// 
+// 
+
+#include "ABMqtt.h"
+
+
+void MqttCallback(char* topic, byte* payload, unsigned int length) {
+	// handle message arrived
+}
+
+void MqttSetup() {
+	WiFiClient espClient;
+	PubSubClient client(espClient);
+
+	long lastReconnectAttempt = 0;
+
+	boolean reconnect() {
+		if (client.connect("arduinoClient")) {
+			// Once connected, publish an announcement...
+			client.publish("outTopic", "hello world");
+			// ... and resubscribe
+			client.subscribe("inTopic");
+		}
+		return client.connected();
+	}
+}
\ No newline at end of file
diff --git a/Arduino/BTCDieselHeater/src/WiFi/ABmqtt.h b/Arduino/BTCDieselHeater/src/WiFi/ABmqtt.h
new file mode 100644
index 0000000..65dc582
--- /dev/null
+++ b/Arduino/BTCDieselHeater/src/WiFi/ABmqtt.h
@@ -0,0 +1,22 @@
+// ABMqtt.h
+
+#ifndef _ABMQTT_h
+#define _ABMQTT_h
+
+#if defined(ARDUINO) && ARDUINO >= 100
+	#include "arduino.h"
+#else
+	#include "WProgram.h"
+#endif
+
+
+#endif
+
+
+#include <PubSubClient.h>
+#include "BTCWifi.h""
+#include "BTCWebServer.h"
+
+        
+void MqttCallback(char* topic, byte* payload, unsigned int length);
+void MqttSetup();