|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: REQUIRED | OPTIONAL | DETAIL: ELEMENT |
@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 |
long |
reaperInterval
interval for the task that checks for timed-out aggregates |
boolean |
sendPartialResultsOnTimeout
indicates whether to send an incomplete aggregate on timeout |
long |
sendTimeout
timeout for sending results to the reply target (in milliseconds) |
long |
timeout
maximum time to wait for completion (in milliseconds) |
int |
trackedCorrelationIdCapacity
maximum number of correlation IDs to maintain so that received messages may be recognized as belonging to an aggregate that has already completed or timed out |
public abstract java.lang.String inputChannel
public abstract java.lang.String outputChannel
public abstract java.lang.String discardChannel
public abstract long sendTimeout
public abstract long timeout
public abstract boolean sendPartialResultsOnTimeout
public abstract long reaperInterval
public abstract int trackedCorrelationIdCapacity
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: REQUIRED | OPTIONAL | DETAIL: ELEMENT |