Class ClusteredTransactionId

java.lang.Object

com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId

public class ClusteredTransactionId
extends Object

Constructor Summary

Constructors

Constructor	Description
ClusteredTransactionId(SwiftletContext ctx, boolean messageBasedDispatch)
ClusteredTransactionId(SwiftletContext ctx, com.swiftmq.swiftlet.queue.AbstractQueue baseQueue, Object baseTx, com.swiftmq.jms.QueueImpl destination)

Method Summary

Modifier and Type	Method	Description
long	commit()
long	commit(com.swiftmq.jms.XidImpl xid)
void	commit(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
Object	getBaseTx()
com.swiftmq.swiftlet.store.CompositeStoreTransaction	getCompositeStoreTransaction()
com.swiftmq.jms.QueueImpl	getDestination()
boolean	isMessageBasedDispatch()
void	lockQueue()
void	prepare(com.swiftmq.jms.XidImpl xid)
void	putMessage(com.swiftmq.jms.MessageImpl message)
void	putMessage(String queueName, com.swiftmq.jms.MessageImpl message)
void	rollback(boolean b)
void	rollback(boolean b, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
void	rollback(com.swiftmq.jms.XidImpl xid, boolean b)
void	setCompositeStoreTransaction(com.swiftmq.swiftlet.store.CompositeStoreTransaction ct)
String	toString()
void	unlockQueue(boolean markAsyncActive)
void	unmarkAsyncActive()

Methods inherited from class Object

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

Constructor Details

ClusteredTransactionId

public ClusteredTransactionId(SwiftletContext ctx,
 boolean messageBasedDispatch)

ClusteredTransactionId

public ClusteredTransactionId(SwiftletContext ctx,
 com.swiftmq.swiftlet.queue.AbstractQueue baseQueue,
 Object baseTx,
 com.swiftmq.jms.QueueImpl destination)

Method Details

isMessageBasedDispatch

public boolean isMessageBasedDispatch()

putMessage

public void putMessage(String queueName,
 com.swiftmq.jms.MessageImpl message)
                throws Exception

Throws:

Exception

putMessage

public void putMessage(com.swiftmq.jms.MessageImpl message)
                throws Exception

Throws:

Exception

getDestination

public com.swiftmq.jms.QueueImpl getDestination()

getBaseTx

public Object getBaseTx()

lockQueue

public void lockQueue()

unlockQueue

public void unlockQueue(boolean markAsyncActive)

unmarkAsyncActive

public void unmarkAsyncActive()

setCompositeStoreTransaction

public void setCompositeStoreTransaction(com.swiftmq.swiftlet.store.CompositeStoreTransaction ct)

getCompositeStoreTransaction

public com.swiftmq.swiftlet.store.CompositeStoreTransaction getCompositeStoreTransaction()

prepare

public void prepare(com.swiftmq.jms.XidImpl xid)
             throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

commit

public long commit(com.swiftmq.jms.XidImpl xid)
            throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

commit

public long commit()
            throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

commit

public void commit(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

rollback

public void rollback(com.swiftmq.jms.XidImpl xid,
 boolean b)
              throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

rollback

public void rollback(boolean b)
              throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

rollback

public void rollback(boolean b,
 com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

toString

public String toString()

Overrides:

toString in class Object