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

java.lang.Object
  extended by org.mule.transport.amqp.internal.transaction.AmqpTransactionFactory
All Implemented Interfaces:
org.mule.api.transaction.TransactionFactory, org.mule.api.transaction.UnboundTransactionFactory, org.mule.api.transaction.UniversalTransactionFactory

public class AmqpTransactionFactory
extends Object
implements org.mule.api.transaction.UniversalTransactionFactory

AmqpTransactionFactory creates an AMQP local transaction.


Field Summary
static AmqpTransaction.RecoverStrategy DEFAULT_RECOVER_STRATEGY
           
 
Constructor Summary
AmqpTransactionFactory()
           
 
Method Summary
 org.mule.api.transaction.Transaction beginTransaction(org.mule.api.MuleContext muleContext)
           
 org.mule.api.transaction.Transaction createUnboundTransaction(org.mule.api.MuleContext muleContext)
           
 AmqpTransaction.RecoverStrategy getRecoverStrategy()
           
 boolean isTransacted()
           
 void setRecoverStrategy(AmqpTransaction.RecoverStrategy recoverStrategy)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_RECOVER_STRATEGY

public static final AmqpTransaction.RecoverStrategy DEFAULT_RECOVER_STRATEGY
Constructor Detail

AmqpTransactionFactory

public AmqpTransactionFactory()
Method Detail

beginTransaction

public org.mule.api.transaction.Transaction beginTransaction(org.mule.api.MuleContext muleContext)
                                                      throws org.mule.api.transaction.TransactionException
Specified by:
beginTransaction in interface org.mule.api.transaction.TransactionFactory
Throws:
org.mule.api.transaction.TransactionException

isTransacted

public boolean isTransacted()
Specified by:
isTransacted in interface org.mule.api.transaction.TransactionFactory

createUnboundTransaction

public org.mule.api.transaction.Transaction createUnboundTransaction(org.mule.api.MuleContext muleContext)
                                                              throws org.mule.api.transaction.TransactionException
Specified by:
createUnboundTransaction in interface org.mule.api.transaction.UnboundTransactionFactory
Throws:
org.mule.api.transaction.TransactionException

getRecoverStrategy

public AmqpTransaction.RecoverStrategy getRecoverStrategy()

setRecoverStrategy

public void setRecoverStrategy(AmqpTransaction.RecoverStrategy recoverStrategy)


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.