All Implemented Interfaces:
public abstract class
extends Message> Object
An aggregation policy that performs a simple map operation
on the given message.
Methods inherited from class java.lang.
Object clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public int getCompletionSize()
Maximum number of messages to be added to a bucket before dispatching.
If this value is <= 1, the buckets should be dispatched immediately after
adding a single element.
getCompletionSize AggregationPolicy< S, T extends Message>
Returns: maximum number of messages per bucket
public int getCompletionIntervalMs()
Maximum number of milliseconds for which buckets should
continue accumulating messages after creation.
If a bucket has been created for longer than this interval, it
will be dispatched regardless of it's current size.
Values <= 0 will disable periodic flushing and buckets will
only be dispatched once they have reached the maximum size.
getCompletionIntervalMs AggregationPolicy< S, T extends Message>
Returns: number of milliseconds to keep a bucket before dispatching
T aggregate( T oldBucket,
Aggregate the given message into an existing bucket, or
create a new bucket if no bucket exists.
aggregate AggregationPolicy< S, T extends Message>
oldBucket - the existing bucket, or
null if a new bucket should be created
newMessage - the message to aggregate
Returns: the new bucket
Copyright © 2017. All rights reserved.