diff --git a/controller-host/main.lua b/controller-host/main.lua
index 3efc7ae..013a4d6 100644
--- a/controller-host/main.lua
+++ b/controller-host/main.lua
@@ -77,6 +77,10 @@ function love.update(...)
 	end
 end
 
+function love.mqtt.onError(message)
+	print("MQTT error")
+end
+
 function love.mqtt.connect(connack)
 	if connack.rc ~= 0 then
 		print("Connection to broker failed:", connack:reason_string())
diff --git a/controller-host/mqttthread.lua b/controller-host/mqttthread.lua
index 9b416f6..08d1fa9 100644
--- a/controller-host/mqttthread.lua
+++ b/controller-host/mqttthread.lua
@@ -58,6 +58,7 @@ local function main()
 		message = onMessage,
 		error = function(message)
 			print("MQTT error: " .. message)
+			call("onError", message)
 		end
 	}