playaround

swisspost · Oct 5, 2023 · c8cefc0 · c8cefc0
1 parent 4783761
commit c8cefc0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/swisspush/reststorage/DefaultRedisProvider.java b/src/main/java/org/swisspush/reststorage/DefaultRedisProvider.java
@@ -97,7 +97,7 @@ private Future<RedisAPI> connectToRedis() {
                     .setPoolRecycleTimeout(redisPoolRecycleTimeoutMs)
                     .setMaxWaitingHandlers(redisMaxPipelineWaitingSize);
             if (configuration.isRedisClustered()) {
-                redisOptions.setType(RedisClientType.CLUSTER);
+                redisOptions.setType(RedisClientType.REPLICATION);
                 redisOptions.addConnectionString(createConnectString());
             } else {
                 redisOptions.setConnectionString(createConnectString());
@@ -107,7 +107,7 @@ private Future<RedisAPI> connectToRedis() {
             redis.connect().onSuccess(conn -> {
                 log.info("Successfully connected to redis");
                 client = conn;
-                client.close();
+             //   client.close();
 
                 // make sure the client is reconnected on error
                 // eg, the underlying TCP connection is closed but the client side doesn't know it yet