Spring Integration

org.springframework.integration.aggregator
Class DefaultAggregatingMessageGroupProcessor

java.lang.Object
  extended by org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor
      extended by org.springframework.integration.aggregator.DefaultAggregatingMessageGroupProcessor
All Implemented Interfaces:
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
DefaultAggregatingMessageGroupProcessor()
           
 
Method Summary
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, processMessageGroup
 
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

Spring Integration