public class DefaultAggregateHeadersFunction extends Object implements java.util.function.Function<MessageGroup,Map<String,Object>>
Function
implementation for a default headers merging in the aggregator
component. It takes all the unique headers from all the messages in group and removes
those which are conflicted: have different values from different messages.AbstractAggregatingMessageGroupProcessor
Constructor and Description |
---|
DefaultAggregateHeadersFunction() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
apply(MessageGroup messageGroup) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen, compose, identity
public Map<String,Object> apply(MessageGroup messageGroup)
apply
in interface java.util.function.Function<MessageGroup,Map<String,Object>>