From d1568c32679628c6a532f03db2c4dd035e4511de Mon Sep 17 00:00:00 2001
From: Jan-Piet Mens <jpmens@gmail.com>
Date: Tue, 23 Feb 2016 09:01:54 +0100
Subject: [PATCH] fix mqtt loop

---
 recorder.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/recorder.c b/recorder.c
index 9acf48d..feacf76 100644
--- a/recorder.c
+++ b/recorder.c
@@ -1680,6 +1680,7 @@ int main(int argc, char **argv)
 
 	while (run) {
 #ifdef WITH_MQTT
+		loop_timeout = 0;
 		rc = mosquitto_loop(mosq, loop_timeout, /* max-packets */ 1);
 		if (run && rc) {
 			olog(LOG_INFO, "MQTT connection: rc=%d [%s] (errno=%d; %s). Sleeping...", rc, mosquitto_strerror(rc), errno, strerror(errno));