diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java b/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java
index 3f90aa3c3..77f573d25 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java
@@ -113,7 +113,7 @@ public class RateLimiter {
       final String bucketName = getBucketName(key);
 
       String serialized = jedis.get(bucketName);
-      redisClusterExperiment.compareFutureResult(serialized, cacheCluster.withReadCluster(connection -> connection.async().get(bucketName)));
+      redisClusterExperiment.compareSupplierResult(serialized, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(bucketName)));
 
       if (serialized != null) {
         return LeakyBucket.fromSerialized(mapper, serialized);
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java
index 9dc0ad57b..9befaa187 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java
@@ -60,7 +60,7 @@ public class AccountDatabaseCrawlerCache {
   public boolean isAccelerated() {
     try (Jedis jedis = jedisPool.getWriteResource()) {
       final String accelerated = jedis.get(ACCELERATE_KEY);
-      redisClusterExperiment.compareFutureResult(accelerated, cacheCluster.withReadCluster(connection -> connection.async().get(ACCELERATE_KEY)));
+      redisClusterExperiment.compareSupplierResult(accelerated, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(ACCELERATE_KEY)));
 
       return "1".equals(accelerated);
     }
@@ -88,7 +88,7 @@ public class AccountDatabaseCrawlerCache {
   public Optional<UUID> getLastUuid() {
     try (Jedis jedis = jedisPool.getWriteResource()) {
       String lastUuidString = jedis.get(LAST_UUID_KEY);
-      redisClusterExperiment.compareFutureResult(lastUuidString, cacheCluster.withWriteCluster(connection -> connection.async().get(LAST_UUID_KEY)));
+      redisClusterExperiment.compareSupplierResult(lastUuidString, () -> cacheCluster.withWriteCluster(connection -> connection.sync().get(LAST_UUID_KEY)));
 
       if (lastUuidString == null) return Optional.empty();
       else                        return Optional.of(UUID.fromString(lastUuidString));
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java
index 4476e2d16..fae8f15af 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java
@@ -179,7 +179,7 @@ public class AccountsManager {
       final String key = getAccountMapKey(number);
 
       String uuid = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(uuid, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(uuid, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       if (uuid != null) return redisGet(jedis, UUID.fromString(uuid));
       else              return Optional.empty();
@@ -203,7 +203,7 @@ public class AccountsManager {
       final String key = getAccountEntityKey(uuid);
 
       String json = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(json, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(json, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       if (json != null) {
         Account account = mapper.readValue(json, Account.class);
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java
index 00cd9f99b..648912b2d 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java
@@ -165,7 +165,7 @@ public class ActiveUserCounter extends AccountDatabaseCrawlerListener {
   private void incrementTallies(UUID fromUuid, Map<String, long[]> platformIncrements, Map<String, long[]> countryIncrements) {
     try (Jedis jedis = jedisPool.getWriteResource()) {
       String tallyValue = jedis.get(TALLY_KEY);
-      redisClusterExperiment.compareFutureResult(tallyValue, cacheCluster.withReadCluster(connection -> connection.async().get(TALLY_KEY)));
+      redisClusterExperiment.compareSupplierResult(tallyValue, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(TALLY_KEY)));
 
       ActiveUserTally activeUserTally;
 
@@ -210,7 +210,7 @@ public class ActiveUserCounter extends AccountDatabaseCrawlerListener {
   private ActiveUserTally getFinalTallies() {
     try (Jedis jedis = jedisPool.getReadResource()) {
       final String tallyJson = jedis.get(TALLY_KEY);
-      redisClusterExperiment.compareFutureResult(tallyJson, cacheCluster.withReadCluster(connection -> connection.async().get(TALLY_KEY)));
+      redisClusterExperiment.compareSupplierResult(tallyJson, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(TALLY_KEY)));
 
       return mapper.readValue(tallyJson, ActiveUserTally.class);
     } catch (IOException e) {
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingAccountsManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingAccountsManager.java
index 290bd8f0f..7e357e31b 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingAccountsManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingAccountsManager.java
@@ -89,7 +89,7 @@ public class PendingAccountsManager {
       final String key = CACHE_PREFIX + number;
 
       String json = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(json, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(json, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       if (json == null) return Optional.empty();
       else              return Optional.of(mapper.readValue(json, StoredVerificationCode.class));
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingDevicesManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingDevicesManager.java
index e023a2ec7..24c050b05 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingDevicesManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/PendingDevicesManager.java
@@ -88,7 +88,7 @@ public class PendingDevicesManager {
       final String key = CACHE_PREFIX + number;
 
       String json = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(json, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(json, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       if (json == null) return Optional.empty();
       else              return Optional.of(mapper.readValue(json, StoredVerificationCode.class));
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ProfilesManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ProfilesManager.java
index a30619613..38551351a 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ProfilesManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ProfilesManager.java
@@ -74,7 +74,7 @@ public class ProfilesManager {
       final String key = CACHE_PREFIX + uuid.toString();
 
       String json = jedis.hget(key, version);
-      redisClusterExperiment.compareFutureResult(json, cacheCluster.withReadCluster(connection -> connection.async().hget(key, version)));
+      redisClusterExperiment.compareSupplierResult(json, () -> cacheCluster.withReadCluster(connection -> connection.sync().hget(key, version)));
 
       if (json == null) return Optional.empty();
       else              return Optional.of(mapper.readValue(json, VersionedProfile.class));
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/UsernamesManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/UsernamesManager.java
index 78d1f320f..4bd329e35 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/UsernamesManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/UsernamesManager.java
@@ -148,7 +148,7 @@ public class UsernamesManager {
       final String key = getUsernameMapKey(username);
 
       String result = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(result, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(result, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       if (result == null) return Optional.empty();
       else                return Optional.of(UUID.fromString(result));
@@ -165,7 +165,7 @@ public class UsernamesManager {
       final String key = getUuidMapKey(uuid);
 
       final String result = jedis.get(key);
-      redisClusterExperiment.compareFutureResult(result, cacheCluster.withReadCluster(connection -> connection.async().get(key)));
+      redisClusterExperiment.compareSupplierResult(result, () -> cacheCluster.withReadCluster(connection -> connection.sync().get(key)));
 
       return Optional.ofNullable(result);
     } catch (JedisException e) {