2 files changed, 51 insertions, 0 deletions

diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt
index 12695ff..183b1bf 100644
--- a/tests/CMakeLists.txt
+++ b/tests/CMakeLists.txt
@@ -18,6 +18,7 @@ manual_tests (
     storagetest
     dummyresourcetest
     domainadaptortest
+    messagequeuetest
 )
 
 target_link_libraries(dummyresourcetest akonadi2_resource_dummy)
diff --git a/tests/messagequeuetest.cpp b/tests/messagequeuetest.cpp
new file mode 100644
index 0000000..2ea9f0c
--- /dev/null
+++ b/tests/messagequeuetest.cpp
@@ -0,0 +1,50 @@
+#include <QtTest>
+
+#include <QString>
+#include <QQueue>
+
+#include "clientapi.h"
+#include "storage.h"
+#include "messagequeue.h"
+
+class MessageQueueTest : public QObject
+{
+    Q_OBJECT
+private Q_SLOTS:
+    void initTestCase()
+    {
+        Akonadi2::Storage store(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue", Akonadi2::Storage::ReadWrite);
+        store.removeFromDisk();
+    }
+
+    void cleanupTestCase()
+    {
+    }
+
+    void testQueue()
+    {
+        QQueue<QByteArray> values;
+        values << "value1";
+        values << "value2";
+
+        MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue");
+        for (const QByteArray &value : values) {
+            queue.enqueue(value.data(), value.size());
+        }
+
+        while (!queue.isEmpty()) {
+            const auto expected = values.dequeue();
+            queue.dequeue([&](void *ptr, int size, std::function<void(bool success)> callback) {
+                QCOMPARE(QByteArray(static_cast<char*>(ptr), size), expected);
+                callback(true);
+            }, [](const MessageQueue::Error &error) {
+
+            });
+        }
+        Q_ASSERT(values.isEmpty());
+    }
+
+};
+
+QTEST_MAIN(MessageQueueTest)
+#include "messagequeuetest.moc"