org.apache.geronimo.connector.outbound
Class SinglePoolConnectionInterceptor

java.lang.Object
  extended by org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor
      extended by org.apache.geronimo.connector.outbound.SinglePoolConnectionInterceptor
All Implemented Interfaces:
ConnectionInterceptor, PoolingAttributes

public class SinglePoolConnectionInterceptor
extends AbstractSinglePoolConnectionInterceptor

SinglePoolConnectionInterceptor chooses a single connection from the pool. If selectOneAssumeMatch is true, it simply returns the selected connection. THIS SHOULD BE USED ONLY IF MAXIMUM SPEED IS ESSENTIAL AND YOU HAVE THOROUGLY CHECKED THAT MATCHING WOULD SUCCEED ON THE SELECTED CONNECTION. (i.e., read the docs on your connector to find out how matching works) If selectOneAssumeMatch is false, it checks with the ManagedConnectionFactory that the selected connection does match before returning it: if not it throws an exception.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor
AbstractSinglePoolConnectionInterceptor.FillTask
 
Field Summary
 
Fields inherited from class org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor
blockingTimeoutMilliseconds, connectionCount, destroyed, maxSize, minSize, next, permits, shrinkLater, timer
 
Constructor Summary
SinglePoolConnectionInterceptor(ConnectionInterceptor next, int maxSize, int minSize, int blockingTimeoutMilliseconds, int idleTimeoutMinutes, boolean selectOneAssumeMatch)
           
 
Method Summary
protected  void doAdd(ManagedConnectionInfo mci)
           
protected  boolean doRemove(ManagedConnectionInfo mci)
           
protected  void getExpiredManagedConnectionInfos(long threshold, List<ManagedConnectionInfo> killList)
           
 int getIdleConnectionCount()
           
protected  Object getPool()
           
protected  void internalDestroy()
           
protected  void internalGetConnection(ConnectionInfo connectionInfo)
           
protected  void transferConnections(int maxSize, int shrinkNow)
           
 
Methods inherited from class org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor
addToPool, destroy, getBlockingTimeoutMilliseconds, getConnection, getConnectionCount, getIdleTimeoutMinutes, getPartitionCount, getPartitionMaxSize, getPartitionMinSize, internalReturn, returnConnection, setBlockingTimeoutMilliseconds, setIdleTimeoutMinutes, setPartitionMaxSize, setPartitionMinSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SinglePoolConnectionInterceptor

public SinglePoolConnectionInterceptor(ConnectionInterceptor next,
                                       int maxSize,
                                       int minSize,
                                       int blockingTimeoutMilliseconds,
                                       int idleTimeoutMinutes,
                                       boolean selectOneAssumeMatch)
Method Detail

internalGetConnection

protected void internalGetConnection(ConnectionInfo connectionInfo)
                              throws ResourceException
Specified by:
internalGetConnection in class AbstractSinglePoolConnectionInterceptor
Throws:
ResourceException

internalDestroy

protected void internalDestroy()
Specified by:
internalDestroy in class AbstractSinglePoolConnectionInterceptor

getPool

protected Object getPool()
Specified by:
getPool in class AbstractSinglePoolConnectionInterceptor

doAdd

protected void doAdd(ManagedConnectionInfo mci)
Specified by:
doAdd in class AbstractSinglePoolConnectionInterceptor

doRemove

protected boolean doRemove(ManagedConnectionInfo mci)
Specified by:
doRemove in class AbstractSinglePoolConnectionInterceptor

transferConnections

protected void transferConnections(int maxSize,
                                   int shrinkNow)
Specified by:
transferConnections in class AbstractSinglePoolConnectionInterceptor

getIdleConnectionCount

public int getIdleConnectionCount()
Specified by:
getIdleConnectionCount in interface PoolingAttributes
Specified by:
getIdleConnectionCount in class AbstractSinglePoolConnectionInterceptor

getExpiredManagedConnectionInfos

protected void getExpiredManagedConnectionInfos(long threshold,
                                                List<ManagedConnectionInfo> killList)
Specified by:
getExpiredManagedConnectionInfos in class AbstractSinglePoolConnectionInterceptor


Copyright © 2003-2010 Apache Software Foundation. All Rights Reserved.