public class IdentityAggregationPolicy<T extends Message> extends Object implements AggregationPolicy<T,T>
Constructor and Description |
---|
IdentityAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
T |
aggregate(T oldBucket,
T newMessage)
Aggregate the given message into an existing bucket, or
create a new bucket if no bucket exists.
|
int |
getCompletionIntervalMs()
Maximum number of milliseconds for which buckets should
continue accumulating messages after creation.
|
int |
getCompletionSize()
Maximum number of messages to be added to a bucket before dispatching.
|
Object |
key(T message)
Calculate a key for the given message.
|
public Object key(T message)
AggregationPolicy
public T aggregate(T oldBucket, T newMessage)
AggregationPolicy
public int getCompletionSize()
AggregationPolicy
getCompletionSize
in interface AggregationPolicy<T extends Message,T extends Message>
public int getCompletionIntervalMs()
AggregationPolicy
getCompletionIntervalMs
in interface AggregationPolicy<T extends Message,T extends Message>
Copyright © 2017. All rights reserved.