|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: REQUIRED | OPTIONAL | DETAIL: ELEMENT |
@Target(value=METHOD) @Retention(value=RUNTIME) @Documented @Handler 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) |
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 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 |