|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageGroup
A group of messages that are correlated with each other and should be processed in the same context. The group is divided into marked and unmarked messages. The marked messages are typically already processed, the unmarked messages are to be processed in the future.
The message group allows implementations to be mutable, but this behavior is optional. Implementations should take care to document their thread safety and mutability.
Method Summary | |
---|---|
boolean |
canAdd(Message<?> message)
Query if the message can be added. |
void |
complete()
|
java.lang.Object |
getGroupId()
|
int |
getLastReleasedMessageSequenceNumber()
Returns the sequenceNumber of the last released message. |
java.util.Collection<Message<?>> |
getMarked()
|
Message<?> |
getOne()
|
int |
getSequenceSize()
|
long |
getTimestamp()
|
java.util.Collection<Message<?>> |
getUnmarked()
|
boolean |
isComplete()
|
int |
size()
|
Method Detail |
---|
boolean canAdd(Message<?> message)
java.util.Collection<Message<?>> getUnmarked()
java.util.Collection<Message<?>> getMarked()
java.lang.Object getGroupId()
int getLastReleasedMessageSequenceNumber()
boolean isComplete()
void complete()
int getSequenceSize()
int size()
Message<?> getOne()
long getTimestamp()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |