cluster: Bugfix for the log timestamps.

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 54a56f22d6a5c93b2af36391ceb858d7421f5108..7810c9a486bd63cd54dc040ca9e9454155e370b5 100644 (file)
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -656,6 +656,8 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
                lmessage->Set("params", lparams);
 
                sender->SendMessage(lmessage);
+
+               sender->SetRemoteLogPosition(message->Get("ts"));
        }
 
        Dictionary::Ptr params = message->Get("params");
@@ -839,7 +841,7 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
                ObjectLock olock(service);
                service->ClearAcknowledgement(sender->GetName());
        } else if (message->Get("method") == "cluster::SetLogPosition") {
-               sender->SetRemoteLogPosition(params->Get("log_position"));
+               sender->SetLocalLogPosition(params->Get("log_position"));
        }
 }