Package org.springframework.integration.aggregator

Class DefaultAggregatingMessageGroupProcessor

java.lang.Object

org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

org.springframework.integration.aggregator.DefaultAggregatingMessageGroupProcessor

All Implemented Interfaces:

Aware, BeanFactoryAware, MessageGroupProcessor

public class DefaultAggregatingMessageGroupProcessor
extends AbstractAggregatingMessageGroupProcessor

This implementation of MessageGroupProcessor will take the messages from the MessageGroup and pass them on in a single message with a Collection as a payload.

Since:

2.0

Author:

Iwein Fuld, Alexander Peters, Mark Fisher

Field Summary

Fields inherited from class org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

logger

Constructor Summary

Constructors

Constructor	Description
DefaultAggregatingMessageGroupProcessor()

Method Summary

Modifier and Type	Method	Description
protected final Object	aggregatePayloads(MessageGroup group, Map<String,Object> headers)

Methods inherited from class org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

aggregateHeaders, getHeadersFunction, getMessageBuilderFactory, processMessageGroup, setBeanFactory, setHeadersFunction

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultAggregatingMessageGroupProcessor

public DefaultAggregatingMessageGroupProcessor()

Method Details

aggregatePayloads

protected final Object aggregatePayloads(MessageGroup group,
 Map<String,Object> headers)

Specified by:

aggregatePayloads in class AbstractAggregatingMessageGroupProcessor