From 68ce437b03ad91711b0d9b03bc134e605882b633 Mon Sep 17 00:00:00 2001 From: Calle Wilund Date: Wed, 17 Aug 2016 08:33:00 +0000 Subject: [PATCH] Gossiper: update to c3 compat --- src/main/java/org/apache/cassandra/gms/Gossiper.java | 4 ++++ src/main/java/org/apache/cassandra/gms/GossiperMBean.java | 2 ++ 2 files changed, 6 insertions(+) diff --git a/src/main/java/org/apache/cassandra/gms/Gossiper.java b/src/main/java/org/apache/cassandra/gms/Gossiper.java index 5b5f7a4..b1c81e7 100644 --- a/src/main/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/main/java/org/apache/cassandra/gms/Gossiper.java @@ -77,17 +77,20 @@ public class Gossiper implements GossiperMBean { } } + @Override public long getEndpointDowntime(String address) throws UnknownHostException { log(" getEndpointDowntime(String address) throws UnknownHostException"); return c.getLongValue("gossiper/downtime/" + address); } + @Override public int getCurrentGenerationNumber(String address) throws UnknownHostException { log(" getCurrentGenerationNumber(String address) throws UnknownHostException"); return c.getIntValue("gossiper/generation_number/" + address); } + @Override public void unsafeAssassinateEndpoint(String address) throws UnknownHostException { log(" unsafeAssassinateEndpoint(String address) throws UnknownHostException"); @@ -96,6 +99,7 @@ public class Gossiper implements GossiperMBean { c.post("gossiper/assassinate/" + address, queryParams); } + @Override public void assassinateEndpoint(String address) throws UnknownHostException { log(" assassinateEndpoint(String address) throws UnknownHostException"); c.post("gossiper/assassinate/" + address, null); diff --git a/src/main/java/org/apache/cassandra/gms/GossiperMBean.java b/src/main/java/org/apache/cassandra/gms/GossiperMBean.java index 521fd21..c4b244c 100644 --- a/src/main/java/org/apache/cassandra/gms/GossiperMBean.java +++ b/src/main/java/org/apache/cassandra/gms/GossiperMBean.java @@ -27,4 +27,6 @@ public interface GossiperMBean public void unsafeAssassinateEndpoint(String address) throws UnknownHostException; + public void assassinateEndpoint(String address) throws UnknownHostException; + } \ No newline at end of file