org.springframework.integration.annotation
Annotation Type Aggregator

@Target(value=METHOD)
@Retention(value=RUNTIME)
@Documented
public @interface Aggregator

Indicates that a method is capable of aggregating messages.

A method annotated with @Aggregator may accept a collection of Messages or Message payloads and should return a single Message or a single Object to be used as a Message payload.

Optional Element Summary

java.lang.String	discardChannel channel name for sending discarded messages (due to a timeout)
java.lang.String	inputChannel channel name for receiving messages to be aggregated
java.lang.String	outputChannel channel name for sending aggregated result messages
boolean	sendPartialResultsOnExpiry indicates whether to send an incomplete aggregate on expiry of the message group
long	sendTimeout timeout for sending results to the reply target (in milliseconds)

inputChannel

public abstract java.lang.String inputChannel

channel name for receiving messages to be aggregated

Default:

""

outputChannel

public abstract java.lang.String outputChannel

channel name for sending aggregated result messages

Default:

""

discardChannel

public abstract java.lang.String discardChannel

channel name for sending discarded messages (due to a timeout)

Default:

""

sendTimeout

public abstract long sendTimeout

timeout for sending results to the reply target (in milliseconds)

Default:

1000L

sendPartialResultsOnExpiry

public abstract boolean sendPartialResultsOnExpiry

indicates whether to send an incomplete aggregate on expiry of the message group

Default:

false