Package com.swiftmq.impl.queue.standard.cluster

Class ClusteredQueue

java.lang.Object

AbstractQueue

com.swiftmq.impl.queue.standard.cluster.ClusteredQueue

public class ClusteredQueue
extends AbstractQueue

Constructor Summary

Constructors

Constructor	Description
ClusteredQueue(SwiftletContext ctx, DispatchPolicy dispatchPolicy)

Method Summary

Modifier and Type	Method	Description
void	commit(Object txId)
void	commit(Object txId, AsyncCompletionCallback callback)
void	commit(Object txId, XidImpl xid)
Object	createPullTransaction()
Object	createPushTransaction()
void	deleteContent()
CompositeStoreTransaction	getCompositeStoreTransaction(Object txId)
boolean	hasReceiver(MessageImpl message)
void	lockQueue(Object txId)
void	prepare(Object txId, XidImpl xid)
void	putMessage(Object txId, MessageImpl message)
void	rollback(Object txId, boolean b)
void	rollback(Object txId, boolean b, AsyncCompletionCallback callback)
void	rollback(Object txId, XidImpl xid, boolean b)
AbstractQueue	selectBaseQueue()
void	setCompositeStoreTransaction(Object txId, CompositeStoreTransaction ct)
void	startQueue()
void	stopQueue()
String	toString()
void	unlockQueue(Object txId, boolean markAsyncActive)
void	unmarkAsyncActive(Object txId)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusteredQueue

public ClusteredQueue(SwiftletContext ctx,
 DispatchPolicy dispatchPolicy)

Method Details

selectBaseQueue

public AbstractQueue selectBaseQueue()

hasReceiver

public boolean hasReceiver(MessageImpl message)

lockQueue

public void lockQueue(Object txId)

unlockQueue

public void unlockQueue(Object txId,
 boolean markAsyncActive)

unmarkAsyncActive

public void unmarkAsyncActive(Object txId)

setCompositeStoreTransaction

public void setCompositeStoreTransaction(Object txId,
 CompositeStoreTransaction ct)

getCompositeStoreTransaction

public CompositeStoreTransaction getCompositeStoreTransaction(Object txId)

createPullTransaction

public Object createPullTransaction()
                             throws QueueException

Throws:

QueueException

createPushTransaction

public Object createPushTransaction()
                             throws QueueException

Throws:

QueueException

putMessage

public void putMessage(Object txId,
 MessageImpl message)
                throws QueueException

Throws:

QueueException

commit

public void commit(Object txId)
            throws QueueException

Throws:

QueueException

commit

public void commit(Object txId,
 AsyncCompletionCallback callback)

rollback

public void rollback(Object txId,
 boolean b)
              throws QueueException

Throws:

QueueException

rollback

public void rollback(Object txId,
 boolean b,
 AsyncCompletionCallback callback)

prepare

public void prepare(Object txId,
 XidImpl xid)
             throws QueueException

Throws:

QueueException

commit

public void commit(Object txId,
 XidImpl xid)
            throws QueueException

Throws:

QueueException

rollback

public void rollback(Object txId,
 XidImpl xid,
 boolean b)
              throws QueueException

Throws:

QueueException

deleteContent

public void deleteContent()
                   throws QueueException

Throws:

QueueException

startQueue

public void startQueue()
                throws QueueException

Throws:

QueueException

stopQueue

public void stopQueue()
               throws QueueException

Throws:

QueueException

toString

public String toString()