org.mule.transport.amqp.internal.transaction
Class AmqpTransactionFactory
java.lang.Object
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_RECOVER_STRATEGY
public static final AmqpTransaction.RecoverStrategy DEFAULT_RECOVER_STRATEGY
AmqpTransactionFactory
public AmqpTransactionFactory()
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.