diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java index bf9dfcbcf..5b78237b3 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java @@ -382,7 +382,6 @@ public class WhisperServerService extends Application> consumer) { this.readCircuitBreaker.executeRunnable(() -> consumer.accept(stringClusterConnection)); } @@ -87,13 +90,4 @@ public class FaultTolerantRedisCluster implements Managed { public T withBinaryWriteCluster(final Function, T> consumer) { return this.writeCircuitBreaker.executeSupplier(() -> consumer.apply(binaryClusterConnection)); } - - @Override - public void start() { - } - - @Override - public void stop() { - clusterClient.shutdown(); - } } diff --git a/service/src/test/java/org/whispersystems/textsecuregcm/redis/AbstractRedisClusterTest.java b/service/src/test/java/org/whispersystems/textsecuregcm/redis/AbstractRedisClusterTest.java index b49598a92..a5eeb4cda 100644 --- a/service/src/test/java/org/whispersystems/textsecuregcm/redis/AbstractRedisClusterTest.java +++ b/service/src/test/java/org/whispersystems/textsecuregcm/redis/AbstractRedisClusterTest.java @@ -64,7 +64,7 @@ public abstract class AbstractRedisClusterTest { @After public void tearDown() throws Exception { - redisCluster.stop(); + redisCluster.shutdown(); } @AfterClass