Package org.springframework.integration.file.aggregator

Class FileMarkerReleaseStrategy

java.lang.Object

org.springframework.integration.file.aggregator.FileMarkerReleaseStrategy

All Implemented Interfaces:

GroupConditionProvider, ReleaseStrategy

public class FileMarkerReleaseStrategy
extends Object
implements ReleaseStrategy, GroupConditionProvider

A ReleaseStrategy which makes a decision based on the presence of FileSplitter.FileMarker.Mark.END message in the group and its FileHeaders.LINE_COUNT header.

The logic of this strategy is based on the GROUP_CONDITION function populated to the AbstractCorrelatingMessageHandler.

Since:

5.5

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
static final BiFunction<Message<?>,String,String>	GROUP_CONDITION	The BiFunction for AbstractCorrelatingMessageHandler.setGroupConditionSupplier(BiFunction).

Constructor Summary

Constructors

Constructor	Description
FileMarkerReleaseStrategy()

Method Summary

Modifier and Type	Method	Description
boolean	canRelease(MessageGroup group)
BiFunction<Message<?>,String,String>	getGroupConditionSupplier()

Methods inherited from class java.lang.Object

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

Field Details

GROUP_CONDITION

public static final BiFunction<Message<?>,String,String> GROUP_CONDITION

The BiFunction for AbstractCorrelatingMessageHandler.setGroupConditionSupplier(BiFunction).

Constructor Details

FileMarkerReleaseStrategy

public FileMarkerReleaseStrategy()

Method Details

canRelease

public boolean canRelease(MessageGroup group)

Specified by:

canRelease in interface ReleaseStrategy

getGroupConditionSupplier

public BiFunction<Message<?>,String,String> getGroupConditionSupplier()

Specified by:

getGroupConditionSupplier in interface GroupConditionProvider