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 void
addMessageToGroup(GroupedMessage msg)
Addsmsg
to the group.GroupedMessageId
getGroupedMessageId()
void
setGroupedMessageId(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)
Addsmsg
to the group. For ordering purposes,msg
will appear after this.- Parameters:
msg
-
-
-