1 files changed, 2 insertions, 0 deletions

diff --git a/common/messagequeue.h b/common/messagequeue.h
index 3393394..c5e32db 100644
--- a/common/messagequeue.h
+++ b/common/messagequeue.h
@@ -4,6 +4,7 @@
 #include <string>
 #include <functional>
 #include <QString>
+#include <Async/Async>
 #include "storage.h"
 
 /**
@@ -32,6 +33,7 @@ public:
     //TODO track processing progress to avoid processing the same message with the same preprocessor twice?
     void dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler,
               const std::function<void(const Error &error)> &errorHandler);
+    KAsync::Job<void> dequeueBatch(int maxBatchSize, const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler);
     bool isEmpty();
 signals:
     void messageReady();