- All Implemented Interfaces:
FileSplitter.FileMarker-based aggregation logic. Implements all three
MessageGroupProcessorfor runtime optimization. Delegates to
with markers enabled is about do not provide a sequence details
headers, therefore correlation in this aggregator implementation is done by the
header which is still populated by the
for each line emitted, including
If default behavior of this component does not satisfy the target logic, it is recommended to configure an aggregator with individual strategies.
- Artem Bilan
Method SummaryModifier and TypeMethodDescription
booleanFind the correlation key for the given message.Process the given MessageGroup.
getCorrelationKeyDescription copied from interface:
CorrelationStrategyFind the correlation key for the given message. If no key can be determined the strategy should not return
null, but throw an exception.
canReleasepublic boolean canRelease
processMessageGroupDescription copied from interface:
MessageGroupProcessorProcess the given MessageGroup. Implementations are free to return as few or as many messages based on the invocation as needed. For example an aggregating processor will return only a single message representing the group, while a resequencing processor will return all messages whose preceding sequence has been satisfied.
If a multiple messages are returned the return value must be a Collection<Message>.