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, waitandThen, compose, identitypublic Map<String,Object> apply(MessageGroup messageGroup)
apply in interface java.util.function.Function<MessageGroup,Map<String,Object>>