blob: 2ea9f0c3605f8419c2d8dc6da4b2457d418e85f0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
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"
|
