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) {