Package com.swiftmq.impl.queue.standard.composite

Class CompositeQueue

AbstractQueue

com.swiftmq.impl.queue.standard.composite.CompositeQueue

public class CompositeQueue
extends AbstractQueue

Constructor Summary

Constructors

Constructor	Description
CompositeQueue(SwiftletContext ctx, Entity compositeQueueEntity)

Method Summary

Modifier and Type	Method	Description
void	commit(Object object)
void	commit(Object object, AsyncCompletionCallback callback)
void	commit(Object object, XidImpl xid)
Object	createPullTransaction()
Object	createPushTransaction()
void	deleteContent()
boolean	hasReceiver(MessageImpl message)
void	lockQueue(Object object)
void	prepare(Object object, XidImpl xid)
void	putMessage(Object object, MessageImpl message)
void	rollback(Object object, boolean setRedelivered)
void	rollback(Object object, boolean setRedelivered, AsyncCompletionCallback callback)
void	rollback(Object object, XidImpl xid, boolean setRedelivered)
void	setCompositeStoreTransaction(Object object, CompositeStoreTransaction ct)
void	startQueue()
void	stopQueue()
void	unlockQueue(Object object, boolean markAsyncActive)

Constructor Details

CompositeQueue

public CompositeQueue(SwiftletContext ctx,
 Entity compositeQueueEntity)

Method Details

lockQueue

public void lockQueue(Object object)

unlockQueue

public void unlockQueue(Object object,
 boolean markAsyncActive)

setCompositeStoreTransaction

public void setCompositeStoreTransaction(Object object,
 CompositeStoreTransaction ct)

hasReceiver

public boolean hasReceiver(MessageImpl message)

createPushTransaction

public Object createPushTransaction()
                             throws QueueException

Throws:

QueueException

createPullTransaction

public Object createPullTransaction()
                             throws QueueException

Throws:

QueueException

putMessage

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

Throws:

QueueException

prepare

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

Throws:

QueueException

commit

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

Throws:

QueueException

commit

public void commit(Object object)
            throws QueueException

Throws:

QueueException

commit

public void commit(Object object,
 AsyncCompletionCallback callback)

rollback

public void rollback(Object object,
 XidImpl xid,
 boolean setRedelivered)
              throws QueueException

Throws:

QueueException

rollback

public void rollback(Object object,
 boolean setRedelivered)
              throws QueueException

Throws:

QueueException

rollback

public void rollback(Object object,
 boolean setRedelivered,
 AsyncCompletionCallback callback)

deleteContent

public void deleteContent()
                   throws QueueException

Throws:

QueueException

startQueue

public void startQueue()
                throws QueueException

Throws:

QueueException

stopQueue

public void stopQueue()
               throws QueueException

Throws:

QueueException