Class TransactionRegistry

java.lang.Object

com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry

public class TransactionRegistry
extends Object

Constructor Summary

Constructors

Constructor	Description
TransactionRegistry(SwiftletContext ctx, SessionHandler sessionHandler)

Method Summary

Modifier and Type	Method	Description
void	addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF txnIdIF, com.swiftmq.amqp.v100.generated.transport.performatives.DispositionFrame frame)
void	addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId, SourceLink sourceLink, long deliveryId, com.swiftmq.swiftlet.queue.MessageIndex messageIndex, long size)
void	addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId, String linkName, com.swiftmq.jms.MessageImpl message, TargetLink targetLink)
void	close()
com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF	createTxId()
void	discharge(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId, boolean rollback)
String	toString()

Methods inherited from class Object

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

Constructor Details

TransactionRegistry

public TransactionRegistry(SwiftletContext ctx,
 SessionHandler sessionHandler)

Method Details

createTxId

public com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF createTxId()

addToTransaction

public void addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId,
 String linkName,
 com.swiftmq.jms.MessageImpl message,
 TargetLink targetLink)
                      throws EndWithErrorException

Throws:

EndWithErrorException

addToTransaction

public void addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId,
 SourceLink sourceLink,
 long deliveryId,
 com.swiftmq.swiftlet.queue.MessageIndex messageIndex,
 long size)
                      throws EndWithErrorException

Throws:

EndWithErrorException

addToTransaction

public void addToTransaction(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF txnIdIF,
 com.swiftmq.amqp.v100.generated.transport.performatives.DispositionFrame frame)
                      throws EndWithErrorException

Throws:

EndWithErrorException

discharge

public void discharge(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF btxnId,
 boolean rollback)
               throws EndWithErrorException

Throws:

EndWithErrorException

close

public void close()

toString

public String toString()

Overrides:

toString in class Object