From 239d2fe9fc349497344833a439d202e7ecd262e8 Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Sun, 16 Aug 2015 12:47:22 +0200 Subject: Use the QByteArray implementation as main implementation --- common/messagequeue.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'common/messagequeue.cpp') diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp index 3b5ca2b..2a046d1 100644 --- a/common/messagequeue.cpp +++ b/common/messagequeue.cpp @@ -43,21 +43,21 @@ MessageQueue::MessageQueue(const QString &storageRoot, const QString &name) } void MessageQueue::enqueue(void const *msg, size_t size) +{ + enqueue(QByteArray::fromRawData(static_cast(msg), size)); +} + +void MessageQueue::enqueue(const QByteArray &value) { auto transaction = std::move(mStorage.createTransaction(Akonadi2::Storage::ReadWrite)); const qint64 revision = Akonadi2::Storage::maxRevision(transaction) + 1; const QByteArray key = QString("%1").arg(revision).toUtf8(); - transaction.write(key, QByteArray::fromRawData(static_cast(msg), size)); + transaction.write(key, value); Akonadi2::Storage::setMaxRevision(transaction, revision); transaction.commit(); emit messageReady(); } -void MessageQueue::enqueue(const QByteArray &value) -{ - enqueue(value.data(), value.size()); -} - void MessageQueue::dequeue(const std::function)> &resultHandler, const std::function &errorHandler) { -- cgit v1.2.3