public class RedisFailoverExecutor extends RedisAbstractExecutor
Modifier and Type | Field and Description |
---|---|
protected RedisExecutor |
executor |
protected int |
timeout |
scripts
Constructor and Description |
---|
RedisFailoverExecutor(int timeout,
RedisExecutor base) |
Modifier and Type | Method and Description |
---|---|
<T> T |
execute(RedisCallable<T> callable) |
protected <T> T |
executeWithRetryPolicy(RedisCallable<T> callable,
Retry.Policy policy) |
redis.clients.util.Pool<redis.clients.jedis.Jedis> |
getPool() |
void |
subscribe(redis.clients.jedis.JedisPubSub subscriber,
String channel)
Run a subscriber, do not return.
|
evalsha, evalsha, scriptLoad
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
psubscribe, startMonitor, stopMonitor
protected final int timeout
protected final RedisExecutor executor
public RedisFailoverExecutor(int timeout, RedisExecutor base)
public <T> T execute(RedisCallable<T> callable) throws redis.clients.jedis.exceptions.JedisConnectionException
redis.clients.jedis.exceptions.JedisConnectionException
public void subscribe(redis.clients.jedis.JedisPubSub subscriber, String channel) throws redis.clients.jedis.exceptions.JedisConnectionException
RedisExecutor
redis.clients.jedis.exceptions.JedisConnectionException
protected <T> T executeWithRetryPolicy(RedisCallable<T> callable, Retry.Policy policy)
public redis.clients.util.Pool<redis.clients.jedis.Jedis> getPool()
Copyright © 2018 Nuxeo. All rights reserved.