org.mule.transport.amqp.internal.transaction
Class AmqpTransaction
java.lang.Object
org.mule.transaction.AbstractTransaction
org.mule.transaction.AbstractSingleResourceTransaction
org.mule.transport.amqp.internal.transaction.AmqpTransaction
- All Implemented Interfaces:
- org.mule.api.transaction.Transaction
public class AmqpTransaction
- extends org.mule.transaction.AbstractSingleResourceTransaction
AmqpTransaction
is a wrapper for an AMQP local transaction. This object holds the AMQP
channel and controls when the transaction is committed or rolled back.
Fields inherited from class org.mule.transaction.AbstractSingleResourceTransaction |
committed, key, resource, rollbackOnly, rolledBack, started, txStatusMappings |
Fields inherited from class org.mule.transaction.AbstractTransaction |
id, logger, muleContext |
Fields inherited from interface org.mule.api.transaction.Transaction |
STATUS_ACTIVE, STATUS_COMMITTED, STATUS_COMMITTING, STATUS_MARKED_ROLLBACK, STATUS_NO_TRANSACTION, STATUS_PREPARED, STATUS_PREPARING, STATUS_ROLLEDBACK, STATUS_ROLLING_BACK, STATUS_UNKNOWN |
Methods inherited from class org.mule.transaction.AbstractSingleResourceTransaction |
begin, commit, getKeyType, getResource, getResourceType, getStatus, hasResource, rollback, setRollbackOnly, supports, toString |
Methods inherited from class org.mule.transaction.AbstractTransaction |
fireNotification, getId, isBegun, isCommitted, isRollbackOnly, isRolledBack, isXA, resume, suspend, unbindTransaction |
AmqpTransaction
public AmqpTransaction(org.mule.api.MuleContext muleContext,
AmqpTransaction.RecoverStrategy recoverStrategy)
bindResource
public void bindResource(Object key,
Object resource)
throws org.mule.api.transaction.TransactionException
- Specified by:
bindResource
in interface org.mule.api.transaction.Transaction
- Overrides:
bindResource
in class org.mule.transaction.AbstractSingleResourceTransaction
- Throws:
org.mule.api.transaction.TransactionException
doBegin
protected void doBegin()
throws org.mule.api.transaction.TransactionException
- Specified by:
doBegin
in class org.mule.transaction.AbstractTransaction
- Throws:
org.mule.api.transaction.TransactionException
doCommit
protected void doCommit()
throws org.mule.api.transaction.TransactionException
- Specified by:
doCommit
in class org.mule.transaction.AbstractTransaction
- Throws:
org.mule.api.transaction.TransactionException
doRollback
protected void doRollback()
throws org.mule.api.transaction.TransactionException
- Specified by:
doRollback
in class org.mule.transaction.AbstractTransaction
- Throws:
org.mule.api.transaction.TransactionException
applyRecoverStrategy
protected void applyRecoverStrategy(com.rabbitmq.client.Channel channel)
getTransactedChannel
public com.rabbitmq.client.Channel getTransactedChannel()
shouldCloseChannel
protected boolean shouldCloseChannel()
closeChannelIfNeeded
protected void closeChannelIfNeeded(com.rabbitmq.client.Channel channel)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.