com.netflix.astyanax.connectionpool.impl
Class AbstractExecuteWithFailoverImpl<CL,R>

java.lang.Object
  extended by 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>


Field Summary
protected  ConnectionPoolConfiguration config
           
protected  Connection<CL> connection
           
 
Constructor Summary
AbstractExecuteWithFailoverImpl(ConnectionPoolConfiguration config, ConnectionPoolMonitor monitor)
           
 
Method Summary
abstract  Connection<CL> borrowConnection(Operation<CL,R> operation)
           
abstract  boolean canRetry()
           
 Host getCurrentHost()
           
abstract  HostConnectionPool<CL> getCurrentHostConnectionPool()
           
 void informException(ConnectionException connectionException)
           
protected  void releaseConnection()
           
 OperationResult<R> tryOperation(Operation<CL,R> operation)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connection

protected Connection<CL> connection

config

protected final ConnectionPoolConfiguration config
Constructor Detail

AbstractExecuteWithFailoverImpl

public AbstractExecuteWithFailoverImpl(ConnectionPoolConfiguration config,
                                       ConnectionPoolMonitor monitor)
                                throws ConnectionException
Throws:
ConnectionException
Method Detail

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.