void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Dictionary::Ptr& message)
{
+ sender->SetSeen(Utility::GetTime());
+
if (message->Contains("ts")) {
double ts = message->Get("ts");
return;
if (message->Get("method") == "cluster::HeartBeat") {
- sender->SetSeen(Utility::GetTime());
-
String identity = params->Get("identity");
Endpoint::Ptr endpoint = Endpoint::GetByName(identity);
- if (endpoint && endpoint != sender)
+ if (endpoint)
endpoint->SetSeen(Utility::GetTime());
} else if (message->Get("method") == "cluster::CheckResult") {
String svc = params->Get("service");