[redis] add ability to specify jedis timeout on the command line (#1455)

This commit is contained in:
Harshavardhan Unnibhavi 2020-09-16 20:51:50 +01:00 коммит произвёл GitHub
Родитель af47d643ca
Коммит 0a43104985
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
1 изменённых файлов: 7 добавлений и 1 удалений

Просмотреть файл

@ -60,6 +60,7 @@ public class RedisClient extends DB {
public static final String PORT_PROPERTY = "redis.port";
public static final String PASSWORD_PROPERTY = "redis.password";
public static final String CLUSTER_PROPERTY = "redis.cluster";
public static final String TIMEOUT_PROPERTY = "redis.timeout";
public static final String INDEX_KEY = "_indices";
@ -81,7 +82,12 @@ public class RedisClient extends DB {
jedisClusterNodes.add(new HostAndPort(host, port));
jedis = new JedisCluster(jedisClusterNodes);
} else {
jedis = new Jedis(host, port);
String redisTimeout = props.getProperty(TIMEOUT_PROPERTY);
if (redisTimeout != null){
jedis = new Jedis(host, port, Integer.parseInt(redisTimeout));
} else {
jedis = new Jedis(host, port);
}
((Jedis) jedis).connect();
}