diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-11 10:30:10 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-11 10:30:10 +0200 |
commit | a9dc9ed667f06fa1828773d1bb8671ec2731dce5 (patch) | |
tree | f8a195992d79d1ff8122be44613e70e04cde0d95 /common/messagequeue.h | |
parent | 3144d1b4bbf523b80fa04ba61787d9366ccc0443 (diff) | |
download | sink-a9dc9ed667f06fa1828773d1bb8671ec2731dce5.tar.gz sink-a9dc9ed667f06fa1828773d1bb8671ec2731dce5.zip |
Fixed messagequeue
Diffstat (limited to 'common/messagequeue.h')
-rw-r--r-- | common/messagequeue.h | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/messagequeue.h b/common/messagequeue.h index ffc1ff2..3393394 100644 --- a/common/messagequeue.h +++ b/common/messagequeue.h | |||
@@ -26,6 +26,7 @@ public: | |||
26 | MessageQueue(const QString &storageRoot, const QString &name); | 26 | MessageQueue(const QString &storageRoot, const QString &name); |
27 | 27 | ||
28 | void enqueue(void const *msg, size_t size); | 28 | void enqueue(void const *msg, size_t size); |
29 | void enqueue(const QByteArray &value); | ||
29 | //Dequeue a message. This will return a new message everytime called. | 30 | //Dequeue a message. This will return a new message everytime called. |
30 | //Call the result handler with a success response to remove the message from the store. | 31 | //Call the result handler with a success response to remove the message from the store. |
31 | //TODO track processing progress to avoid processing the same message with the same preprocessor twice? | 32 | //TODO track processing progress to avoid processing the same message with the same preprocessor twice? |
@@ -39,5 +40,4 @@ signals: | |||
39 | private: | 40 | private: |
40 | Q_DISABLE_COPY(MessageQueue); | 41 | Q_DISABLE_COPY(MessageQueue); |
41 | Akonadi2::Storage mStorage; | 42 | Akonadi2::Storage mStorage; |
42 | Akonadi2::Storage::Transaction mTransaction; | ||
43 | }; | 43 | }; |