Package org.springframework.integration.aggregator

Class DefaultAggregateHeadersFunction

java.lang.Object

org.springframework.integration.aggregator.DefaultAggregateHeadersFunction

All Implemented Interfaces:

Function<MessageGroup,Map<String,Object>>

public class DefaultAggregateHeadersFunction
extends Object
implements 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	Description
DefaultAggregateHeadersFunction()

Method Summary

Modifier and Type	Method	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

Constructor Details

DefaultAggregateHeadersFunction

public DefaultAggregateHeadersFunction()

Method Details

apply

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

Specified by:

apply in interface Function<MessageGroup,Map<String,Object>>