bitronix.tm.resource.jms

Class JmsPooledConnection

java.lang.Object

bitronix.tm.resource.common.AbstractXAStatefulHolder<JmsPooledConnection>

bitronix.tm.resource.jms.JmsPooledConnection

All Implemented Interfaces:

XAStatefulHolder<JmsPooledConnection>, JmsPooledConnectionMBean

public class JmsPooledConnection
extends AbstractXAStatefulHolder<JmsPooledConnection>
implements JmsPooledConnectionMBean

Implementation of a JMS pooled connection wrapping vendor's XAConnection implementation.

Author:

Ludovic Orban TODO: how can the JMS connection be accurately tested?

Nested Class Summary

Nested classes/interfaces inherited from interface bitronix.tm.resource.common.XAStatefulHolder

XAStatefulHolder.State

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JmsPooledConnection(PoolingConnectionFactory poolingConnectionFactory, javax.jms.XAConnection connection)

Method Summary

Modifier and Type	Method and Description
void	close() Close the physical connection that this XAStatefulHolder represents.
RecoveryXAResourceHolder	createRecoveryXAResourceHolder()
protected javax.jms.Session	createSession(boolean transacted, int acknowledgeMode)
Date	getAcquisitionDate()
Object	getConnectionHandle() Create a disposable handler used to drive a pooled instance of XAStatefulHolder.
Date	getLastReleaseDate() Get the date at which this object was last released to the pool.
PoolingConnectionFactory	getPoolingConnectionFactory()
String	getStateDescription()
Collection<String>	getTransactionGtridsCurrentlyHoldingThis()
javax.jms.XAConnection	getXAConnection()
DualSessionWrapper	getXAResourceHolderForXaResource(XAResource xaResource)
List<DualSessionWrapper>	getXAResourceHolders() Get the list of XAResourceHolders created by this XAStatefulHolder that are still open.
protected void	release()
String	toString()

Methods inherited from class bitronix.tm.resource.common.AbstractXAStatefulHolder

addStateChangeEventListener, getCreationDate, getState, removeStateChangeEventListener, setState

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsPooledConnection

protected JmsPooledConnection(PoolingConnectionFactory poolingConnectionFactory,
                              javax.jms.XAConnection connection)

Method Detail

getXAConnection

public javax.jms.XAConnection getXAConnection()

getPoolingConnectionFactory

public PoolingConnectionFactory getPoolingConnectionFactory()

createRecoveryXAResourceHolder

public RecoveryXAResourceHolder createRecoveryXAResourceHolder()
                                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Description copied from interface: XAStatefulHolder

Close the physical connection that this XAStatefulHolder represents.

Specified by:

close in interface XAStatefulHolder<JmsPooledConnection>

Throws:

javax.jms.JMSException

getXAResourceHolders

public List<DualSessionWrapper> getXAResourceHolders()

Description copied from interface: XAStatefulHolder

Get the list of XAResourceHolders created by this XAStatefulHolder that are still open.

This method is thread-safe.

Specified by:

getXAResourceHolders in interface XAStatefulHolder<JmsPooledConnection>

Returns:

the list of XAResourceHolders created by this XAStatefulHolder that are still open.

getConnectionHandle

public Object getConnectionHandle()
                           throws Exception

Description copied from interface: XAStatefulHolder

Create a disposable handler used to drive a pooled instance of XAStatefulHolder.

This method is thread-safe.

Specified by:

getConnectionHandle in interface XAStatefulHolder<JmsPooledConnection>

Returns:

a resource-specific disposable connection object.

Throws:

Exception - a resource-specific exception thrown when the disposable connection cannot be created.

release

protected void release()
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createSession

protected javax.jms.Session createSession(boolean transacted,
                                          int acknowledgeMode)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getLastReleaseDate

public Date getLastReleaseDate()

Description copied from interface: XAStatefulHolder

Get the date at which this object was last released to the pool. This is required to check if it is eligible for discard when the containing pool needs to shrink.

Specified by:

getLastReleaseDate in interface XAStatefulHolder<JmsPooledConnection>

Returns:

the date at which this object was last released to the pool or null if it never left the pool.

toString

public String toString()

Overrides:

toString in class Object

getStateDescription

public String getStateDescription()

Specified by:

getStateDescription in interface JmsPooledConnectionMBean

getAcquisitionDate

public Date getAcquisitionDate()

Specified by:

getAcquisitionDate in interface JmsPooledConnectionMBean

getTransactionGtridsCurrentlyHoldingThis

public Collection<String> getTransactionGtridsCurrentlyHoldingThis()

Specified by:

getTransactionGtridsCurrentlyHoldingThis in interface JmsPooledConnectionMBean

getXAResourceHolderForXaResource

public DualSessionWrapper getXAResourceHolderForXaResource(XAResource xaResource)