Close connections before closing the whole cluster client.

2020-08-05 16:12:56 -04:00 · 2020-08-05 16:12:56 -04:00 · e0f8a28f38
parent bf1b00b163
commit e0f8a28f38
1 changed files with 3 additions and 0 deletions
--- a/service/src/main/java/org/whispersystems/textsecuregcm/redis/FaultTolerantRedisCluster.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/redis/FaultTolerantRedisCluster.java
@ -56,6 +56,9 @@ public class FaultTolerantRedisCluster {
    }

    void shutdown() {
+        stringClusterConnection.close();
+        binaryClusterConnection.close();
+
        clusterClient.shutdown();
    }