DATAKV-3 - Update to use Jedis 1.3.0

This commit is contained in:
Mark Pollack
2010-11-01 13:21:17 -04:00
parent bb6f5e269f
commit c00795f5be
2 changed files with 6 additions and 5 deletions

View File

@@ -88,7 +88,7 @@
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>1.1.1</version>
<version>1.3.0</version>
<scope>compile</scope>
</dependency>

View File

@@ -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());
}