summaryrefslogtreecommitdiffstats
path: root/common/genericresource.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/genericresource.cpp')
-rw-r--r--common/genericresource.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp
index 112ce64..3ffc56b 100644
--- a/common/genericresource.cpp
+++ b/common/genericresource.cpp
@@ -107,14 +107,15 @@ private slots:
107 [queue]() { return !queue->isEmpty(); }, 107 [queue]() { return !queue->isEmpty(); },
108 [this, queue](KAsync::Future<void> &future) { 108 [this, queue](KAsync::Future<void> &future) {
109 queue->dequeueBatch(100, [this](const QByteArray &data) { 109 queue->dequeueBatch(100, [this](const QByteArray &data) {
110 Trace() << "Got value";
111 return processQueuedCommand(data); 110 return processQueuedCommand(data);
112 } 111 }
113 ).then<void>([&future, queue](){ 112 ).then<void>([&future, queue](){
114 future.setFinished(); 113 future.setFinished();
115 }, 114 },
116 [&future](int i, QString error) { 115 [&future](int i, QString error) {
117 Warning() << "Error while getting message from messagequeue: " << error; 116 if (i != MessageQueue::ErrorCodes::NoMessageFound) {
117 Warning() << "Error while getting message from messagequeue: " << error;
118 }
118 future.setFinished(); 119 future.setFinished();
119 }).exec(); 120 }).exec();
120 } 121 }