From 642207654e39466b916a33f3d90bd917f67aaea1 Mon Sep 17 00:00:00 2001 From: Imranmech Date: Fri, 26 Apr 2024 14:53:09 +0530 Subject: [PATCH] rhos sentinel changes added --- .../java/com/fynd/extension/storage/RedisStorage.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/main/java/com/fynd/extension/storage/RedisStorage.java b/src/main/java/com/fynd/extension/storage/RedisStorage.java index 4910a38..e342a06 100644 --- a/src/main/java/com/fynd/extension/storage/RedisStorage.java +++ b/src/main/java/com/fynd/extension/storage/RedisStorage.java @@ -10,6 +10,7 @@ public class RedisStorage extends BaseStorage { private JedisPool jedisPool; private JedisCluster jedisCluster; private String prefixKey; + private JedisSentinelPool jedisSentinelPool; public RedisStorage(JedisPool jedisPool, String prefixKey) { super(prefixKey); @@ -25,6 +26,13 @@ public RedisStorage(JedisCluster jedisCluster, String prefixKey) { this.isClusterMode = true; } + public RedisStorage(JedisSentinelPool jedisSentinelPool, String prefixKey) { + super(prefixKey); + this.jedisSentinelPool = jedisSentinelPool; + this.prefixKey = prefixKey; + this.isClusterMode = false; // Sentinel doesn't use clustering + } + @Override public String get(String key) { if (isClusterMode) {