summaryrefslogtreecommitdiffstats
path: root/common/messagequeue.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-01-15 00:53:54 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-01-15 00:53:54 +0100
commit70bb707903da21103b84e0f3effcaa0a24612d5c (patch)
tree9ceac185dd2d6e3a314014563e5596b557afcb78 /common/messagequeue.h
parentccd61612c51d7f8a92349a2d4855efc583a35b5b (diff)
downloadsink-70bb707903da21103b84e0f3effcaa0a24612d5c.tar.gz
sink-70bb707903da21103b84e0f3effcaa0a24612d5c.zip
Fixed messagequeue
Diffstat (limited to 'common/messagequeue.h')
-rw-r--r--common/messagequeue.h8
1 files changed, 7 insertions, 1 deletions
diff --git a/common/messagequeue.h b/common/messagequeue.h
index b56b3cd..8783421 100644
--- a/common/messagequeue.h
+++ b/common/messagequeue.h
@@ -1,5 +1,6 @@
1#pragma once 1#pragma once
2 2
3#include <QObject>
3#include <string> 4#include <string>
4#include <functional> 5#include <functional>
5#include <QString> 6#include <QString>
@@ -8,7 +9,9 @@
8/** 9/**
9 * A persistent FIFO message queue. 10 * A persistent FIFO message queue.
10 */ 11 */
11class MessageQueue { 12class MessageQueue : public QObject
13{
14 Q_OBJECT
12public: 15public:
13 class Error 16 class Error
14 { 17 {
@@ -29,6 +32,9 @@ public:
29 void dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler, 32 void dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler,
30 const std::function<void(const Error &error)> &errorHandler); 33 const std::function<void(const Error &error)> &errorHandler);
31 bool isEmpty(); 34 bool isEmpty();
35signals:
36 void messageReady();
37
32private: 38private:
33 Akonadi2::Storage mStorage; 39 Akonadi2::Storage mStorage;
34}; 40};