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 dfa01e7e1..0b5efaec0 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java @@ -132,14 +132,17 @@ public class RateLimiter { logger.warn("Deserialization error", e); } - try { - final String serialized = secondaryCacheCluster.withCluster(connection -> connection.sync().get(getBucketName(key))); + if (secondaryCacheCluster != null) { + try { + final String serialized = secondaryCacheCluster + .withCluster(connection -> connection.sync().get(getBucketName(key))); - if (serialized != null) { - return LeakyBucket.fromSerialized(mapper, serialized); + if (serialized != null) { + return LeakyBucket.fromSerialized(mapper, serialized); + } + } catch (IOException e) { + logger.warn("Deserialization error", e); } - } catch (IOException e) { - logger.warn("Deserialization error", e); } return new LeakyBucket(bucketSize, leakRatePerMillis);