com.netflix.astyanax.connectionpool.impl
Class RoundRobinExecuteWithFailover<CL,R>
java.lang.Object
com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl<CL,R>
com.netflix.astyanax.connectionpool.impl.RoundRobinExecuteWithFailover<CL,R>
- All Implemented Interfaces:
- ExecuteWithFailover<CL,R>
public class RoundRobinExecuteWithFailover<CL,R>
- extends AbstractExecuteWithFailoverImpl<CL,R>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
pool
protected HostConnectionPool<CL> pool
pools
protected final List<HostConnectionPool<CL>> pools
size
protected int size
waitDelta
protected int waitDelta
waitMultiplier
protected int waitMultiplier
RoundRobinExecuteWithFailover
public RoundRobinExecuteWithFailover(ConnectionPoolConfiguration config,
ConnectionPoolMonitor monitor,
List<HostConnectionPool<CL>> pools,
int index)
throws ConnectionException
- Throws:
ConnectionException
getNextHostIndex
public int getNextHostIndex()
canRetry
public boolean canRetry()
- Specified by:
canRetry
in class AbstractExecuteWithFailoverImpl<CL,R>
getCurrentHostConnectionPool
public HostConnectionPool<CL> getCurrentHostConnectionPool()
- Specified by:
getCurrentHostConnectionPool
in class AbstractExecuteWithFailoverImpl<CL,R>
borrowConnection
public Connection<CL> borrowConnection(Operation<CL,R> operation)
throws ConnectionException
- Specified by:
borrowConnection
in class AbstractExecuteWithFailoverImpl<CL,R>
- Throws:
ConnectionException
Copyright © 2012. All Rights Reserved.