diff --git a/consul/client.go b/consul/client.go index b0ca744882..74dbc3fba7 100644 --- a/consul/client.go +++ b/consul/client.go @@ -190,6 +190,9 @@ func (c *Client) lanEventHandler() { c.nodeFail(e.(serf.MemberEvent)) case serf.EventUser: c.localEvent(e.(serf.UserEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore + case serf.EventQuery: // Ignore default: c.logger.Printf("[WARN] consul: unhandled LAN Serf Event: %#v", e) } diff --git a/consul/serf.go b/consul/serf.go index 4e03661dbe..31a19444db 100644 --- a/consul/serf.go +++ b/consul/serf.go @@ -18,8 +18,11 @@ func (s *Server) lanEventHandler() { fallthrough case serf.EventMemberFailed: s.localMemberEvent(e.(serf.MemberEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore case serf.EventUser: s.localEvent(e.(serf.UserEvent)) + case serf.EventQuery: // Ignore default: s.logger.Printf("[WARN] consul: unhandled LAN Serf Event: %#v", e) } @@ -42,7 +45,10 @@ func (s *Server) wanEventHandler() { fallthrough case serf.EventMemberFailed: s.remoteFailed(e.(serf.MemberEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore case serf.EventUser: + case serf.EventQuery: // Ignore default: s.logger.Printf("[WARN] consul: unhandled WAN Serf Event: %#v", e) }