|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageQueue<E>
Provides abstract API for a queue.
Method Summary | |
---|---|
void |
acknowledge(java.lang.String msgId)
Acknowledges the receipt of a message |
void |
addMessageCallback(MessageCallback<E> messageCallback,
boolean isAutoAck)
Registers a message callback with the queue. |
E |
receive(long expireTime,
boolean isAutoAck)
Synchronous/blocking message receiving. |
QueueEntry<E> |
receiveEntry(long expireTime,
boolean isAutoAck)
Synchronous/blocking message receiving. |
void |
removeMessageCallback(MessageCallback<E> entryCallback)
Removes the callback when messages are done listening |
void |
rollback(java.lang.String msgId)
Rollback a message read |
void |
send(java.lang.String msgId,
E msg,
int priority,
long expireTime,
java.lang.String publisherId)
Sends a message to the destination |
Method Detail |
---|
void send(java.lang.String msgId, E msg, int priority, long expireTime, java.lang.String publisherId) throws MessageException
MessageException
QueueEntry<E> receiveEntry(long expireTime, boolean isAutoAck) throws MessageException
MessageException
E receive(long expireTime, boolean isAutoAck) throws MessageException
MessageException
void addMessageCallback(MessageCallback<E> messageCallback, boolean isAutoAck) throws MessageException
MessageException
void removeMessageCallback(MessageCallback<E> entryCallback)
void rollback(java.lang.String msgId)
void acknowledge(java.lang.String msgId)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |