@Target(value=METHOD) @Retention(value=RUNTIME) @Documented public @interface Aggregator
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.
Modifier and Type | Optional Element and Description |
---|---|
String |
discardChannel
channel name for sending discarded messages (due to a timeout)
|
String |
inputChannel
channel name for receiving messages to be aggregated
|
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)
|
public abstract String inputChannel
public abstract String outputChannel
public abstract String discardChannel
Copyright © 2017. All rights reserved.