com.netflix.astyanax.connectionpool.impl
Class BagOfConnectionsConnectionPoolImpl<CL>

java.lang.Object
  extended by com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool<CL>
      extended by com.netflix.astyanax.connectionpool.impl.BagOfConnectionsConnectionPoolImpl<CL>
Type Parameters:
CL -
All Implemented Interfaces:
ConnectionPool<CL>, SimpleHostConnectionPool.Listener<CL>

public class BagOfConnectionsConnectionPoolImpl<CL>
extends AbstractHostPartitionConnectionPool<CL>

Connection pool which puts all connections in a single queue. The load balancing is essentially random here.

Author:
elandau

Field Summary
 
Fields inherited from class com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool
config, factory, hosts, monitor, topology
 
Constructor Summary
BagOfConnectionsConnectionPoolImpl(ConnectionPoolConfiguration config, ConnectionFactory<CL> factory, ConnectionPoolMonitor monitor)
           
 
Method Summary
<R> ExecuteWithFailover<CL,R>
newExecuteWithFailover(Operation<CL,R> op)
          Return a new failover context.
protected  boolean returnConnection(Connection<CL> connection)
           
 
Methods inherited from class com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool
addHost, executeWithFailover, getActivePools, getHostPool, hasHost, isHostUp, newHostConnectionPool, onHostDown, onHostUp, rebuildPartitions, removeHost, setHosts, shutdown, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BagOfConnectionsConnectionPoolImpl

public BagOfConnectionsConnectionPoolImpl(ConnectionPoolConfiguration config,
                                          ConnectionFactory<CL> factory,
                                          ConnectionPoolMonitor monitor)
Method Detail

returnConnection

protected boolean returnConnection(Connection<CL> connection)

newExecuteWithFailover

public <R> ExecuteWithFailover<CL,R> newExecuteWithFailover(Operation<CL,R> op)
                                                 throws ConnectionException
Description copied from class: AbstractHostPartitionConnectionPool
Return a new failover context. The context captures the connection pool state and implements the necessary failover logic.

Specified by:
newExecuteWithFailover in class AbstractHostPartitionConnectionPool<CL>
Returns:
Throws:
ConnectionException


Copyright © 2012. All Rights Reserved.