Package org.springframework.integration.aggregator

Class SimpleMessageGroupProcessor

java.lang.Object

org.springframework.integration.aggregator.SimpleMessageGroupProcessor

All Implemented Interfaces:

MessageGroupProcessor

public class SimpleMessageGroupProcessor
extends Object
implements MessageGroupProcessor

A MessageGroupProcessor that simply returns the messages in the group. It can be used to configure an aggregator as a barrier, such that when the group is complete, the grouped messages are released as individual messages.

Since:

4.2

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
SimpleMessageGroupProcessor()

Method Summary

Modifier and Type	Method	Description
Object	processMessageGroup(MessageGroup group)	Process the given MessageGroup.

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleMessageGroupProcessor

public SimpleMessageGroupProcessor()

Method Details

processMessageGroup

public Object processMessageGroup(MessageGroup group)

Description copied from interface: MessageGroupProcessor

Process the given MessageGroup. Implementations are free to return as few or as many messages based on the invocation as needed. For example an aggregating processor will return only a single message representing the group, while a resequencing processor will return all messages whose preceding sequence has been satisfied.

If a multiple messages are returned the return value must be a Collection<Message>.

Specified by:

processMessageGroup in interface MessageGroupProcessor

Parameters:

group - The message group.

Returns:

The result of processing the group.