Package org.springframework.integration.file.aggregator

Class FileAggregatingMessageGroupProcessor

java.lang.Object

org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

org.springframework.integration.file.aggregator.FileAggregatingMessageGroupProcessor

All Implemented Interfaces:

Aware, BeanFactoryAware, MessageGroupProcessor

public class FileAggregatingMessageGroupProcessor
extends AbstractAggregatingMessageGroupProcessor

An AbstractAggregatingMessageGroupProcessor implementation for file content collecting previously splitted by the FileSplitter with the markers option turned on.

If no file markers present in the MessageGroup, then behavior of this processor is similar to the DefaultAggregatingMessageGroupProcessor.

When no file content (only file markers are grouped), this processor emits an empty ArrayList. Note: with no file content and markers turned off, the FileSplitter doesn't emit any messages for possible aggregation downstream.

Since:

5.5

Author:

Artem Bilan

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
FileAggregatingMessageGroupProcessor()

Method Summary

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

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

FileAggregatingMessageGroupProcessor

public FileAggregatingMessageGroupProcessor()

Method Details

aggregatePayloads

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

Specified by:

aggregatePayloads in class AbstractAggregatingMessageGroupProcessor