From 734dc2e37acf15764f487f129819387f0669f410 Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Wed, 17 Jun 2020 22:39:23 -0400
Subject: [PATCH] Don't block the Redis instance when clearing the cache.

---
 .../textsecuregcm/workers/ClearCacheClusterCommand.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
index 02a03263b..622e0d1d9 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
@@ -15,6 +15,6 @@ public class ClearCacheClusterCommand extends ConfiguredCommand<WhisperServerCon
     @Override
     protected void run(final Bootstrap<WhisperServerConfiguration> bootstrap, final Namespace namespace, final WhisperServerConfiguration config) {
         final FaultTolerantRedisCluster cacheCluster = new FaultTolerantRedisCluster("main_cache_cluster", config.getCacheClusterConfiguration().getUrls(), config.getCacheClusterConfiguration().getTimeout(), config.getCacheClusterConfiguration().getCircuitBreakerConfiguration());
-        cacheCluster.useWriteCluster(connection -> connection.sync().flushall());
+        cacheCluster.useWriteCluster(connection -> connection.sync().flushallAsync());
     }
 }