Package com.attivio.sdk.esb
Interface GroupedMessage
-
- All Superinterfaces:
java.lang.Cloneable,PlatformMessage,java.io.Serializable
- All Known Implementing Classes:
BulkUpdate,DocumentList
public interface GroupedMessage extends PlatformMessage
Grouped messages are processed in order relative to each other and are guaranteed to all fall on the same side of a commit/optimize/backup boundary. Only messages which implement this interface can participate in groups.
-
-
Field Summary
-
Fields inherited from interface com.attivio.sdk.esb.PlatformMessage
DEFAULT_MAX_LOG_LENGTH, MESSAGE_DROPPED, MESSAGE_SEND_TIME_PROP, PROP_MAX_LOG_LENGTH
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidaddMessageToGroup(GroupedMessage msg)Addsmsgto the group.GroupedMessageIdgetGroupedMessageId()voidsetGroupedMessageId(GroupedMessageId groupedMessageId)Sets the GroupedMessageId for this message.-
Methods inherited from interface com.attivio.sdk.esb.PlatformMessage
addMessageHistory, addMessageHistory, clone, getClientId, getEstimatedSize, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageString
-
-
-
-
Method Detail
-
getGroupedMessageId
GroupedMessageId getGroupedMessageId()
- Returns:
- the GroupedMessageId for this message
-
setGroupedMessageId
void setGroupedMessageId(GroupedMessageId groupedMessageId)
Sets the GroupedMessageId for this message. This method should normally be used only for the first message in the group with subsequent messages being added to the group viaaddMessageToGroup(GroupedMessage).- Parameters:
groupedMessageId-
-
addMessageToGroup
void addMessageToGroup(GroupedMessage msg)
Addsmsgto the group. For ordering purposes,msgwill appear after this.- Parameters:
msg-
-
-