org.springframework.integration.aggregator

Class DefaultAggregatingMessageGroupProcessor

java.lang.Object

org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

org.springframework.integration.aggregator.DefaultAggregatingMessageGroupProcessor

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.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

Constructor Summary

Constructors

Constructor and Description
DefaultAggregatingMessageGroupProcessor()

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	aggregatePayloads(MessageGroup group, java.util.Map<java.lang.String,java.lang.Object> headers)

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

aggregateHeaders, getMessageBuilderFactory, processMessageGroup, setBeanFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAggregatingMessageGroupProcessor

public DefaultAggregatingMessageGroupProcessor()

Method Detail

aggregatePayloads

protected final java.lang.Object aggregatePayloads(MessageGroup group,
                                                   java.util.Map<java.lang.String,java.lang.Object> headers)

Specified by:

aggregatePayloads in class AbstractAggregatingMessageGroupProcessor