diff --git a/mqttclient/main.go b/mqttclient/main.go
index 7f0092f0fdcfd095d8a60e03ecec35bb0ef9a4ba..5480c266aef5b09d47992ac4b77fb98567d03b0c 100644
--- a/mqttclient/main.go
+++ b/mqttclient/main.go
@@ -43,6 +43,10 @@ var messagePubHandlerBoiler mqtt.MessageHandler = func(client mqtt.Client, msg m
 
 var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
 	log.Log.Info("Successfully connected to MQTT broker")
+}
+
+var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
+	log.Log.Error("Connection to MQTT broker lost: ", err.Error())
 	if os.Getenv("EXIT_ON_DISCONNECT") == "true" {
 		log.Log.Info("Sleeping 10s before exiting")
 		time.Sleep(10 * time.Second)
@@ -50,10 +54,6 @@ var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
 	}
 }
 
-var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
-	log.Log.Error("Connection to MQTT broker lost: ", err.Error())
-}
-
 func Init() {
 	opts := mqtt.NewClientOptions()
 	opts.AddBroker(fmt.Sprintf("tcp://%s:%s", os.Getenv("MQTT_HOST"), os.Getenv("MQTT_PORT")))