1 files changed, 7 insertions, 1 deletions

diff --git a/common/listener.cpp b/common/listener.cpp
index 0742017..c3c6bc2 100644
--- a/common/listener.cpp
+++ b/common/listener.cpp
@@ -245,7 +245,13 @@ void Listener::processCommand(int commandId, uint messageId, const QByteArray &c
                 timer->start();
                 auto job = KAsync::null<void>();
                 if (buffer->sourceSync()) {
-                    job = loadResource().synchronizeWithSource();
+                    Sink::QueryBase query;
+                    if (buffer->query()) {
+                        auto data = QByteArray::fromStdString(buffer->query()->str());
+                        QDataStream stream(&data, QIODevice::ReadOnly);
+                        stream >> query;
+                    }
+                    job = loadResource().synchronizeWithSource(query);
                 }
                 if (buffer->localSync()) {
                     job = job.then<void>(loadResource().processAllMessages());