Continue processing if there are more messages.

1 files changed, 14 insertions, 0 deletions

diff --git a/dummyresource/resourcefactory.cpp b/dummyresource/resourcefactory.cpp
index 9d702a8..d94284c 100644
--- a/dummyresource/resourcefactory.cpp
+++ b/dummyresource/resourcefactory.cpp
@@ -122,6 +122,17 @@ public:
 signals:
     void error(int errorCode, const QString &errorMessage);
 
+private:
+    bool messagesToProcessAvailable()
+    {
+        for (auto queue : mCommandQueues) {
+            if (!queue->isEmpty()) {
+                return true;
+            }
+        }
+        return false;
+    }
+
 private slots:
     void process()
     {
@@ -131,6 +142,9 @@ private slots:
         mProcessingLock = true;
         auto job = processPipeline().then<void>([this]() {
             mProcessingLock = false;
+            if (messagesToProcessAvailable()) {
+                process();
+            }
         }).exec();
     }