diff --git a/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java b/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java index ed26084e2..070b22feb 100644 --- a/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java +++ b/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java @@ -210,6 +210,14 @@ public int getPendingCompactions() { return cmProxy.getPendingTasks(); } + /** + * Terminates all ongoing repairs on the node this proxy is connected to + */ + public void cancelAllRepairs() { + checkNotNull(ssProxy, "Looks like the proxy is not connected"); + ssProxy.forceTerminateAllRepairSessions(); + } + /** * Triggers a repair of range (beginToken, endToken] for given keyspace and column family. *