diff --git a/apps/aqhome-mqttlog/main.c b/apps/aqhome-mqttlog/main.c
index bc4637c..09c6318 100644
--- a/apps/aqhome-mqttlog/main.c
+++ b/apps/aqhome-mqttlog/main.c
@@ -210,8 +210,7 @@ int _serve(GWEN_DB_NODE *dbArgs)
     else {
       GWEN_MSG *msg;
 
-      msg=GWEN_MsgEndpoint_TakeFirstReceivedMessage(epTcp);
-      if (msg) {
+      while( (msg=GWEN_MsgEndpoint_TakeFirstReceivedMessage(epTcp)) ) {
 #ifdef FULL_DEBUG
 	DBG_ERROR(NULL, "Received this message:");
 	GWEN_Text_DumpString((const char*) GWEN_Msg_GetConstBuffer(msg), GWEN_Msg_GetBytesInBuffer(msg), 2);