org.apache.geronimo.connector.outbound
Class AbstractConnectionManager

java.lang.Object
  org.apache.geronimo.connector.outbound.AbstractConnectionManager

All Implemented Interfaces:

Serializable, ConnectionManager, LazyAssociatableConnectionManager, ConnectionManagerContainer, PoolingAttributes

Direct Known Subclasses:

GenericConnectionManager

public abstract class AbstractConnectionManager
extends Object
implements ConnectionManagerContainer, ConnectionManager, LazyAssociatableConnectionManager, PoolingAttributes

Version:

$Rev: 585309 $ $Date: 2007-10-16 20:54:22 -0400 (Tue, 16 Oct 2007) $

See Also:

Serialized Form

Nested Class Summary

static interface

AbstractConnectionManager.Interceptors

Field Summary

protected AbstractConnectionManager.Interceptors

interceptors

Constructor Summary

AbstractConnectionManager()

AbstractConnectionManager(AbstractConnectionManager.Interceptors interceptors, RecoverableTransactionManager transactionManager)

Method Summary

Object	allocateConnection(ManagedConnectionFactory managedConnectionFactory, ConnectionRequestInfo connectionRequestInfo) in: mcf !
void	associateConnection(Object connection, ManagedConnectionFactory managedConnectionFactory, ConnectionRequestInfo connectionRequestInfo) in: non-null connection object, from non-null mcf.
Object	createConnectionFactory(ManagedConnectionFactory mcf)
void	doFail()
void	doRecovery(ManagedConnectionFactory managedConnectionFactory)
void	doStart()
void	doStop()
int	getBlockingTimeoutMilliseconds()
int	getConnectionCount()
protected ConnectionManager	getConnectionManager()
int	getIdleConnectionCount()
int	getIdleTimeoutMinutes()
int	getPartitionCount()
int	getPartitionMaxSize()
int	getPartitionMinSize()
PoolingSupport	getPooling()
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

Field Detail

interceptors

protected final AbstractConnectionManager.Interceptors interceptors

Constructor Detail

AbstractConnectionManager

public AbstractConnectionManager()

AbstractConnectionManager

public AbstractConnectionManager(AbstractConnectionManager.Interceptors interceptors,
                                 RecoverableTransactionManager transactionManager)

Method Detail

createConnectionFactory

public Object createConnectionFactory(ManagedConnectionFactory mcf)
                               throws ResourceException

Specified by:

createConnectionFactory in interface ConnectionManagerContainer

Throws:

ResourceException

getConnectionManager

protected ConnectionManager getConnectionManager()

doRecovery

public void doRecovery(ManagedConnectionFactory managedConnectionFactory)

Specified by:

doRecovery in interface ConnectionManagerContainer

allocateConnection

public Object allocateConnection(ManagedConnectionFactory managedConnectionFactory,
                                 ConnectionRequestInfo connectionRequestInfo)
                          throws ResourceException

in: mcf != null, is a deployed mcf out: useable connection object.

Specified by:

allocateConnection in interface ConnectionManager

Throws:

ResourceException

associateConnection

public void associateConnection(Object connection,
                                ManagedConnectionFactory managedConnectionFactory,
                                ConnectionRequestInfo connectionRequestInfo)
                         throws ResourceException

in: non-null connection object, from non-null mcf. connection object is not associated with a managed connection out: supplied connection object is assiciated with a non-null ManagedConnection from mcf.

Specified by:

associateConnection in interface LazyAssociatableConnectionManager

Throws:

ResourceException

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

getPooling

public PoolingSupport getPooling()

doStart

public void doStart()
             throws Exception

Throws:

Exception

doStop

public void doStop()
            throws Exception

Throws:

Exception

doFail

public void doFail()