Don't create a transaction for every appended message.

We create now only one transaction for the whole sync which is also not
ideal.

1 files changed, 4 insertions, 3 deletions

diff --git a/common/synchronizer.h b/common/synchronizer.h
index 6f98f35..9c0e2e2 100644
--- a/common/synchronizer.h
+++ b/common/synchronizer.h
@@ -24,8 +24,8 @@
 #include <Async/Async>
 #include <domainadaptor.h>
 #include <query.h>
-
-#include "storage.h"
+#include <messagequeue.h>
+#include <storage.h>
 
 namespace Sink {
 class EntityStore;
@@ -40,7 +40,7 @@ public:
     Synchronizer(const QByteArray &resourceType, const QByteArray &resourceInstanceIdentifier);
     virtual ~Synchronizer();
 
-    void setup(const std::function<void(int commandId, const QByteArray &data)> &enqueueCommandCallback);
+    void setup(const std::function<void(int commandId, const QByteArray &data)> &enqueueCommandCallback, MessageQueue &messageQueue);
     KAsync::Job<void> synchronize();
 
     //Read only access to main storage
@@ -105,6 +105,7 @@ private:
     Sink::Storage::Transaction mTransaction;
     Sink::Storage::Transaction mSyncTransaction;
     std::function<void(int commandId, const QByteArray &data)> mEnqueue;
+    MessageQueue *mMessageQueue;
 };
 
 }