org.mule.transport.amqp.internal.transaction
Class AmqpTransaction

java.lang.Object
  extended by org.mule.transaction.AbstractTransaction
      extended by org.mule.transaction.AbstractSingleResourceTransaction
          extended by 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.


Nested Class Summary
static class AmqpTransaction.RecoverStrategy
           
 
Field Summary
 
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
 
Constructor Summary
AmqpTransaction(org.mule.api.MuleContext muleContext, AmqpTransaction.RecoverStrategy recoverStrategy)
           
 
Method Summary
protected  void applyRecoverStrategy(com.rabbitmq.client.Channel channel)
           
 void bindResource(Object key, Object resource)
           
protected  void closeChannelIfNeeded(com.rabbitmq.client.Channel channel)
           
protected  void doBegin()
           
protected  void doCommit()
           
protected  void doRollback()
           
 com.rabbitmq.client.Channel getTransactedChannel()
           
protected  boolean shouldCloseChannel()
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AmqpTransaction

public AmqpTransaction(org.mule.api.MuleContext muleContext,
                       AmqpTransaction.RecoverStrategy recoverStrategy)
Method Detail

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.