org.apache.geronimo.connector.outbound

Class MultiPoolConnectionInterceptor

java.lang.Object

org.apache.geronimo.connector.outbound.MultiPoolConnectionInterceptor

All Implemented Interfaces:

ConnectionInterceptor, PoolingAttributes

public class MultiPoolConnectionInterceptor
extends Object
implements ConnectionInterceptor, PoolingAttributes

MultiPoolConnectionInterceptor maps the provided subject and connection request info to a "SinglePool". This can be used to make sure all matches will succeed, avoiding synchronization slowdowns. Created: Fri Oct 10 12:53:11 2003

Version:

$Rev$ $Date$

Constructor Summary

Constructors

Constructor and Description
MultiPoolConnectionInterceptor(ConnectionInterceptor next, PoolingSupport singlePoolFactory, boolean useSubject, boolean useCRI)

Method Summary

Modifier and Type	Method and Description
void	destroy()
int	getBlockingTimeoutMilliseconds()
void	getConnection(ConnectionInfo connectionInfo)
int	getConnectionCount()
int	getIdleConnectionCount()
int	getIdleTimeoutMinutes()
int	getPartitionCount()
int	getPartitionMaxSize()
int	getPartitionMinSize()
void	info(StringBuilder s)
void	returnConnection(ConnectionInfo connectionInfo, ConnectionReturnAction connectionReturnAction)
void	setBlockingTimeoutMilliseconds(int timeoutMilliseconds)
void	setIdleTimeoutMinutes(int idleTimeoutMinutes)
void	setPartitionMaxSize(int maxSize)
void	setPartitionMinSize(int minSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiPoolConnectionInterceptor

public MultiPoolConnectionInterceptor(ConnectionInterceptor next,
                                      PoolingSupport singlePoolFactory,
                                      boolean useSubject,
                                      boolean useCRI)

Method Detail

getConnection

public void getConnection(ConnectionInfo connectionInfo)
                   throws javax.resource.ResourceException

Specified by:

getConnection in interface ConnectionInterceptor

Throws:

javax.resource.ResourceException

returnConnection

public void returnConnection(ConnectionInfo connectionInfo,
                             ConnectionReturnAction connectionReturnAction)

Specified by:

returnConnection in interface ConnectionInterceptor

destroy

public void destroy()

Specified by:

destroy in interface ConnectionInterceptor

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface PoolingAttributes

getPartitionMaxSize

public int getPartitionMaxSize()

Specified by:

getPartitionMaxSize in interface PoolingAttributes

setPartitionMaxSize

public void setPartitionMaxSize(int maxSize)
                         throws InterruptedException

Specified by:

setPartitionMaxSize in interface PoolingAttributes

Throws:

InterruptedException

getPartitionMinSize

public int getPartitionMinSize()

Specified by:

getPartitionMinSize in interface PoolingAttributes

setPartitionMinSize

public void setPartitionMinSize(int minSize)

Specified by:

setPartitionMinSize in interface PoolingAttributes

getIdleConnectionCount

public int getIdleConnectionCount()

Specified by:

getIdleConnectionCount in interface PoolingAttributes

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface PoolingAttributes

getBlockingTimeoutMilliseconds

public int getBlockingTimeoutMilliseconds()

Specified by:

getBlockingTimeoutMilliseconds in interface PoolingAttributes

setBlockingTimeoutMilliseconds

public void setBlockingTimeoutMilliseconds(int timeoutMilliseconds)

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

info

public void info(StringBuilder s)

Specified by:

info in interface ConnectionInterceptor