com.mulesoft.mule.runtime.bti.internal.xa

Class QueueManagerXaResourceProducer

java.lang.Object

bitronix.tm.resource.common.ResourceBean

com.mulesoft.mule.runtime.bti.internal.xa.QueueManagerXaResourceProducer

All Implemented Interfaces:

bitronix.tm.resource.common.XAResourceProducer, Serializable, Referenceable

public class QueueManagerXaResourceProducer
extends bitronix.tm.resource.common.ResourceBean
implements bitronix.tm.resource.common.XAResourceProducer

wrapper for a QueueManager

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
QueueManagerXaResourceProducer(org.mule.runtime.core.api.util.queue.QueueManager queueManager, String uniqueName)

Method Summary

Modifier and Type	Method and Description
void	addXaResource(XAResource session)
void	close()
bitronix.tm.resource.common.XAStatefulHolder	createPooledConnection(Object xaFactory, bitronix.tm.resource.common.ResourceBean bean)
void	endRecovery()
bitronix.tm.resource.common.XAResourceHolder	findXAResourceHolder(XAResource xaResource)
Reference	getReference()
String	getUniqueName()
void	init()
boolean	isFailed()
void	removeXaResource(XAResource xaResource)
void	setFailed(boolean failed)
bitronix.tm.internal.XAResourceHolderState	startRecovery()

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

getAcquireIncrement, getAcquisitionInterval, getAcquisitionTimeout, getAllowLocalTransactions, getApplyTransactionTimeout, getAutomaticEnlistingEnabled, getClassName, getDeferConnectionRelease, getDriverProperties, getIgnoreRecoveryFailures, getMaxIdleTime, getMaxPoolSize, getMinPoolSize, getShareTransactionConnections, getTwoPcOrderingPosition, getUseTmJoin, incCreatedResourcesCounter, isDisabled, setAcquireIncrement, setAcquisitionInterval, setAcquisitionTimeout, setAllowLocalTransactions, setApplyTransactionTimeout, setAutomaticEnlistingEnabled, setClassName, setDeferConnectionRelease, setDisabled, setDriverProperties, setIgnoreRecoveryFailures, setMaxIdleTime, setMaxPoolSize, setMinPoolSize, setShareTransactionConnections, setTwoPcOrderingPosition, setUniqueName, setUseTmJoin

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueManagerXaResourceProducer

public QueueManagerXaResourceProducer(org.mule.runtime.core.api.util.queue.QueueManager queueManager,
                                      String uniqueName)

Method Detail

getUniqueName

public String getUniqueName()

Specified by:

getUniqueName in interface bitronix.tm.resource.common.XAResourceProducer

Overrides:

getUniqueName in class bitronix.tm.resource.common.ResourceBean

startRecovery

public bitronix.tm.internal.XAResourceHolderState startRecovery()
                                                         throws bitronix.tm.recovery.RecoveryException

Specified by:

startRecovery in interface bitronix.tm.resource.common.XAResourceProducer

Throws:

bitronix.tm.recovery.RecoveryException

endRecovery

public void endRecovery()
                 throws bitronix.tm.recovery.RecoveryException

Specified by:

endRecovery in interface bitronix.tm.resource.common.XAResourceProducer

Throws:

bitronix.tm.recovery.RecoveryException

setFailed

public void setFailed(boolean failed)

Specified by:

setFailed in interface bitronix.tm.resource.common.XAResourceProducer

isFailed

public boolean isFailed()

findXAResourceHolder

public bitronix.tm.resource.common.XAResourceHolder findXAResourceHolder(XAResource xaResource)

Specified by:

findXAResourceHolder in interface bitronix.tm.resource.common.XAResourceProducer

init

public void init()

Specified by:

init in interface bitronix.tm.resource.common.XAResourceProducer

close

public void close()

Specified by:

close in interface bitronix.tm.resource.common.XAResourceProducer

createPooledConnection

public bitronix.tm.resource.common.XAStatefulHolder createPooledConnection(Object xaFactory,
                                                                           bitronix.tm.resource.common.ResourceBean bean)
                                                                    throws Exception

Specified by:

createPooledConnection in interface bitronix.tm.resource.common.XAResourceProducer

Throws:

Exception

getReference

public Reference getReference()
                       throws NamingException

Specified by:

getReference in interface Referenceable

Throws:

NamingException

addXaResource

public void addXaResource(XAResource session)

removeXaResource

public void removeXaResource(XAResource xaResource)