public abstract class JedisClusterCommand<T>
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private java.lang.ThreadLocal<Jedis> |
askConnection |
private JedisClusterConnectionHandler |
connectionHandler |
private int |
redirections |
| Constructor and Description |
|---|
JedisClusterCommand(JedisClusterConnectionHandler connectionHandler,
int maxRedirections) |
| Modifier and Type | Method and Description |
|---|---|
abstract T |
execute(Jedis connection) |
private void |
releaseConnection(Jedis connection,
boolean broken) |
T |
run(java.lang.String key) |
private T |
runWithRetries(java.lang.String key,
int redirections,
boolean tryRandomNode,
boolean asking) |
private JedisClusterConnectionHandler connectionHandler
private int redirections
private java.lang.ThreadLocal<Jedis> askConnection
public JedisClusterCommand(JedisClusterConnectionHandler connectionHandler, int maxRedirections)