org.springframework.integration.aggregator

Class DefaultAggregateHeadersFunction

java.lang.Object

org.springframework.integration.aggregator.DefaultAggregateHeadersFunction

All Implemented Interfaces:

java.util.function.Function<MessageGroup,Map<String,Object>>

public class DefaultAggregateHeadersFunction
extends Object
implements java.util.function.Function<MessageGroup,Map<String,Object>>

The 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.

Since:

5.2

Author:

Artem Bilan

See Also:

AbstractAggregatingMessageGroupProcessor

Constructor Summary

Constructors

Constructor and Description
DefaultAggregateHeadersFunction()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	apply(MessageGroup messageGroup)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

DefaultAggregateHeadersFunction

public DefaultAggregateHeadersFunction()

Method Detail

apply

public Map<String,Object> apply(MessageGroup messageGroup)

Specified by:

apply in interface java.util.function.Function<MessageGroup,Map<String,Object>>