diff --git a/service/src/test/java/org/whispersystems/textsecuregcm/configuration/LocalFaultTolerantRedisClusterFactory.java b/service/src/test/java/org/whispersystems/textsecuregcm/configuration/LocalFaultTolerantRedisClusterFactory.java index f9e181cad..7c78314d1 100644 --- a/service/src/test/java/org/whispersystems/textsecuregcm/configuration/LocalFaultTolerantRedisClusterFactory.java +++ b/service/src/test/java/org/whispersystems/textsecuregcm/configuration/LocalFaultTolerantRedisClusterFactory.java @@ -22,6 +22,9 @@ private LocalFaultTolerantRedisClusterFactory() { try { redisClusterExtension.beforeAll(null); redisClusterExtension.beforeEach(null); + + redisClusterExtension.getRedisCluster().useCluster(connection -> + connection.sync().upstream().commands().configSet("notify-keyspace-events", "K$glz")); } catch (final Exception e) { throw new RuntimeException(e); }