org.nuxeo.ecm.core.redis

Class RedisFailoverExecutor

java.lang.Object

org.nuxeo.ecm.core.redis.RedisFailoverExecutor

All Implemented Interfaces:

RedisExecutor

public class RedisFailoverExecutor
extends Object
implements RedisExecutor

Field Summary

Fields

Modifier and Type	Field and Description
protected RedisExecutor	executor
protected int	timeout

Fields inherited from interface org.nuxeo.ecm.core.redis.RedisExecutor

NOOP

Constructor Summary

Constructors

Constructor and Description
RedisFailoverExecutor(int timeout, RedisExecutor base)

Method Summary

Modifier and Type	Method and Description
<T> T	execute(RedisCallable<T> callable)
redis.clients.util.Pool<redis.clients.jedis.Jedis>	getPool()
boolean	supportPipelined() Is the executor support pipelined operations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

timeout

protected final int timeout

executor

protected final RedisExecutor executor

Constructor Detail

RedisFailoverExecutor

public RedisFailoverExecutor(int timeout,
                             RedisExecutor base)

Method Detail

execute

public <T> T execute(RedisCallable<T> callable)
              throws redis.clients.jedis.exceptions.JedisConnectionException

Specified by:

execute in interface RedisExecutor

Throws:

redis.clients.jedis.exceptions.JedisConnectionException

getPool

public redis.clients.util.Pool<redis.clients.jedis.Jedis> getPool()

Specified by:

getPool in interface RedisExecutor

supportPipelined

public boolean supportPipelined()

Description copied from interface: RedisExecutor

Is the executor support pipelined operations

Specified by:

supportPipelined in interface RedisExecutor