aqhome-mqttlog: read all messages available on each loop.

2023-07-18 10:51:16 +02:00
parent f30c4895fa
commit 3efb83ecfd
1 changed files with 1 additions and 2 deletions
--- 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);