diff --git a/spring-datastore-redis/pom.xml b/spring-datastore-redis/pom.xml index acb62366e..dee93ba27 100644 --- a/spring-datastore-redis/pom.xml +++ b/spring-datastore-redis/pom.xml @@ -88,7 +88,7 @@ redis.clients jedis - 1.1.1 + 1.3.0 compile diff --git a/spring-datastore-redis/src/main/java/org/springframework/datastore/redis/core/jedis/JedisClientFactory.java b/spring-datastore-redis/src/main/java/org/springframework/datastore/redis/core/jedis/JedisClientFactory.java index fba7c8304..edcadd191 100644 --- a/spring-datastore-redis/src/main/java/org/springframework/datastore/redis/core/jedis/JedisClientFactory.java +++ b/spring-datastore-redis/src/main/java/org/springframework/datastore/redis/core/jedis/JedisClientFactory.java @@ -27,6 +27,7 @@ import org.springframework.datastore.redis.core.jredis.JRedisPersistenceExceptio import org.springframework.datastore.redis.support.RedisPersistenceExceptionTranslator; import redis.clients.jedis.Jedis; +import redis.clients.jedis.JedisShardInfo; import redis.clients.util.ShardInfo; /** @@ -38,7 +39,7 @@ import redis.clients.util.ShardInfo; */ public class JedisClientFactory extends AbstractRedisClientFactory { - private ShardInfo shardInfo; + private JedisShardInfo shardInfo; private int timeout; @@ -65,11 +66,11 @@ public class JedisClientFactory extends AbstractRedisClientFactory { setTimeout(timeout); } - public JedisClientFactory(ShardInfo shardInfo) { + public JedisClientFactory(JedisShardInfo shardInfo) { this.shardInfo = shardInfo; } - protected ShardInfo getShardInfo() { + protected JedisShardInfo getShardInfo() { return this.shardInfo; } @@ -83,7 +84,7 @@ public class JedisClientFactory extends AbstractRedisClientFactory { @Override public RedisClient doGetClient() { - Jedis jedis; + Jedis jedis; if (getShardInfo() != null) { jedis = new Jedis(getShardInfo()); }