org.apache.geronimo.connector.outbound
Class AbstractSinglePoolConnectionInterceptor
java.lang.Object
org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor
- All Implemented Interfaces:
- ConnectionInterceptor, PoolingAttributes
- Direct Known Subclasses:
- SinglePoolConnectionInterceptor, SinglePoolMatchAllConnectionInterceptor
- public abstract class AbstractSinglePoolConnectionInterceptor
- extends Object
- implements ConnectionInterceptor, PoolingAttributes
- Version:
- $Rev: 356645 $ $Date: 2005-12-14 00:28:40 +0100 (Wed, 14 Dec 2005) $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected static org.apache.commons.logging.Log log
next
protected final ConnectionInterceptor next
permits
protected EDU.oswego.cs.dl.util.concurrent.FIFOSemaphore permits
blockingTimeoutMilliseconds
protected int blockingTimeoutMilliseconds
connectionCount
protected int connectionCount
timer
protected Timer timer
maxSize
protected int maxSize
minSize
protected int minSize
shrinkLater
protected int shrinkLater
destroyed
protected volatile boolean destroyed
AbstractSinglePoolConnectionInterceptor
public AbstractSinglePoolConnectionInterceptor(ConnectionInterceptor next,
int maxSize,
int minSize,
int blockingTimeoutMilliseconds,
int idleTimeoutMinutes)
getConnection
public void getConnection(ConnectionInfo connectionInfo)
throws javax.resource.ResourceException
- Specified by:
getConnection
in interface ConnectionInterceptor
- Throws:
javax.resource.ResourceException
internalGetConnection
protected abstract void internalGetConnection(ConnectionInfo connectionInfo)
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
returnConnection
public void returnConnection(ConnectionInfo connectionInfo,
ConnectionReturnAction connectionReturnAction)
- Specified by:
returnConnection
in interface ConnectionInterceptor
internalReturn
protected abstract boolean internalReturn(ConnectionInfo connectionInfo,
ConnectionReturnAction connectionReturnAction)
internalDestroy
protected abstract void internalDestroy()
destroy
public void destroy()
- Specified by:
destroy
in interface ConnectionInterceptor
getPartitionCount
public int getPartitionCount()
- Specified by:
getPartitionCount
in interface PoolingAttributes
getPartitionMaxSize
public abstract int getPartitionMaxSize()
- Specified by:
getPartitionMaxSize
in interface PoolingAttributes
setPartitionMaxSize
public void setPartitionMaxSize(int newMaxSize)
throws InterruptedException
- Specified by:
setPartitionMaxSize
in interface PoolingAttributes
- Throws:
InterruptedException
transferConnections
protected abstract void transferConnections(int maxSize,
int shrinkNow)
getIdleConnectionCount
public abstract int getIdleConnectionCount()
- Specified by:
getIdleConnectionCount
in interface PoolingAttributes
getConnectionCount
public int getConnectionCount()
- Specified by:
getConnectionCount
in interface PoolingAttributes
getPartitionMinSize
public int getPartitionMinSize()
- Specified by:
getPartitionMinSize
in interface PoolingAttributes
setPartitionMinSize
public void setPartitionMinSize(int minSize)
- Specified by:
setPartitionMinSize
in interface PoolingAttributes
getBlockingTimeoutMilliseconds
public int getBlockingTimeoutMilliseconds()
- Specified by:
getBlockingTimeoutMilliseconds
in interface PoolingAttributes
setBlockingTimeoutMilliseconds
public void setBlockingTimeoutMilliseconds(int blockingTimeoutMilliseconds)
- Specified by:
setBlockingTimeoutMilliseconds
in interface PoolingAttributes
getIdleTimeoutMinutes
public int getIdleTimeoutMinutes()
- Specified by:
getIdleTimeoutMinutes
in interface PoolingAttributes
setIdleTimeoutMinutes
public void setIdleTimeoutMinutes(int idleTimeoutMinutes)
- Specified by:
setIdleTimeoutMinutes
in interface PoolingAttributes
getExpiredManagedConnectionInfos
protected abstract void getExpiredManagedConnectionInfos(long threshold,
ArrayList killList)
addToPool
protected abstract boolean addToPool(ManagedConnectionInfo mci)
Copyright © 2003-2007 Apache Software Foundation. All Rights Reserved.