A messagequeue.

1 files changed, 34 insertions, 0 deletions

diff --git a/common/messagequeue.h b/common/messagequeue.h
new file mode 100644
index 0000000..b56b3cd
--- /dev/null
+++ b/common/messagequeue.h
@@ -0,0 +1,34 @@
+#pragma once
+
+#include <string>
+#include <functional>
+#include <QString>
+#include "storage.h"
+
+/**
+ * A persistent FIFO message queue.
+ */
+class MessageQueue {
+public:
+    class Error
+    {
+    public:
+        Error(const std::string &s, int c, const std::string &m)
+            : store(s), message(m), code(c) {}
+        std::string store;
+        std::string message;
+        int code;
+    };
+
+    MessageQueue(const QString &storageRoot, const QString &name);
+
+    void enqueue(void const *msg, size_t size);
+    //Dequeue a message. This will return a new message everytime called.
+    //Call the result handler with a success response to remove the message from the store.
+    //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);
+    bool isEmpty();
+private:
+    Akonadi2::Storage mStorage;
+};