Package org.mule.jms.commons.internal.connection

Class JmsTransactionalConnection

java.lang.Object

org.mule.jms.commons.internal.connection.JmsConnection

org.mule.jms.commons.internal.connection.JmsTransactionalConnection

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.extension.api.connectivity.TransactionalConnection, org.mule.sdk.api.connectivity.TransactionalConnection, org.mule.sdk.api.tx.Transactional

Direct Known Subclasses:

XaJmsTransactionalConnection

public class JmsTransactionalConnection
extends JmsConnection
implements org.mule.runtime.extension.api.connectivity.TransactionalConnection

Implementation of the JmsConnection which implements TransactionalConnection for Transaction Support in the JmsConnector

Since:

1.0

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Stoppable

PHASE_NAME

Constructor Summary

Constructors

Constructor	Description
JmsTransactionalConnection(JmsSupport jmsSupport, jakarta.jms.Connection connection, JmsSessionManager jmsSessionManager, CompositeJmsExceptionListener exceptionListener)

Method Summary

Modifier and Type	Method	Description
void	begin()	Begins a new Transaction for a JMS Session indicating in the JmsSessionManager that the current Thread is being part of a transaction.
void	commit()	Executes a commit action over the bound JmsSession to the current Thread
void	rollback()	Executes a rollback action over the bound JmsSession to the current Thread

Methods inherited from class org.mule.jms.commons.internal.connection.JmsConnection

createConsumer, createConsumer, createProducer, createSession, dispose, get, getJmsSessionManager, getJmsSupport, registerExceptionListener, removeExceptionListener, setConnection, stop

Methods inherited from class java.lang.Object

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

Constructor Details

JmsTransactionalConnection

public JmsTransactionalConnection(JmsSupport jmsSupport,
 jakarta.jms.Connection connection,
 JmsSessionManager jmsSessionManager,
 CompositeJmsExceptionListener exceptionListener)

Method Details

begin

public void begin()

Begins a new Transaction for a JMS Session indicating in the JmsSessionManager that the current Thread is being part of a transaction.

Specified by:

begin in interface org.mule.sdk.api.tx.Transactional

commit

public void commit()
            throws org.mule.runtime.api.tx.TransactionException

Executes a commit action over the bound JmsSession to the current Thread

Specified by:

commit in interface org.mule.sdk.api.tx.Transactional

Throws:

org.mule.runtime.api.tx.TransactionException

rollback

public void rollback()
              throws org.mule.runtime.api.tx.TransactionException

Executes a rollback action over the bound JmsSession to the current Thread

Specified by:

rollback in interface org.mule.sdk.api.tx.Transactional

Throws:

org.mule.runtime.api.tx.TransactionException