public class IdentityAggregationPolicy<T extends Message> extends Object implements AggregationPolicy<T,T,T>
Constructor and Description |
---|
IdentityAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
T |
aggregate(T accumulator,
T newMessage)
Aggregate the given message into an existing accumulator, or
create a new accumulator if no accumulator exists.
|
T |
build(T accumulator)
Build the resulting message from the accumulator.
|
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 accumulator, T newMessage)
AggregationPolicy
public T build(T accumulator)
AggregationPolicy
public int getCompletionSize()
AggregationPolicy
getCompletionSize
in interface AggregationPolicy<T extends Message,T extends Message,T extends Message>
public int getCompletionIntervalMs()
AggregationPolicy
getCompletionIntervalMs
in interface AggregationPolicy<T extends Message,T extends Message,T extends Message>
Copyright © 2018. All rights reserved.