com.netflix.astyanax.connectionpool.impl
Class AbstractExecuteWithFailoverImpl<CL,R>
java.lang.Object
com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl<CL,R>
- All Implemented Interfaces:
- ExecuteWithFailover<CL,R>
- Direct Known Subclasses:
- RoundRobinExecuteWithFailover
public abstract class AbstractExecuteWithFailoverImpl<CL,R>
- extends Object
- implements ExecuteWithFailover<CL,R>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connection
protected Connection<CL> connection
config
protected final ConnectionPoolConfiguration config
AbstractExecuteWithFailoverImpl
public AbstractExecuteWithFailoverImpl(ConnectionPoolConfiguration config,
ConnectionPoolMonitor monitor)
throws ConnectionException
- Throws:
ConnectionException
getCurrentHost
public final Host getCurrentHost()
getCurrentHostConnectionPool
public abstract HostConnectionPool<CL> getCurrentHostConnectionPool()
borrowConnection
public abstract Connection<CL> borrowConnection(Operation<CL,R> operation)
throws ConnectionException
- Throws:
ConnectionException
canRetry
public abstract boolean canRetry()
tryOperation
public OperationResult<R> tryOperation(Operation<CL,R> operation)
throws ConnectionException
- Specified by:
tryOperation
in interface ExecuteWithFailover<CL,R>
- Throws:
ConnectionException
releaseConnection
protected void releaseConnection()
informException
public void informException(ConnectionException connectionException)
throws ConnectionException
- Throws:
ConnectionException
Copyright © 2012. All Rights Reserved.