Package org.opennms.core.ipc.sink.aggregation

Class Summary

Class	Description
AggregatingMessageProducer<S,T>	A MessageDispatcher that applies the SinkModule's AggregationPolicy using the Aggregator.
AggregatingSinkMessageProducer<S extends Message,T extends Message>	A MessageDispatcher that applies the SinkModule's AggregationPolicy using the Aggregator.
Aggregator<S,T>	This aggregator is used to realize a given AggregationPolicy.
ArrayListAggregationPolicy<S>	An aggregation policy that creates ArrayList aggregates.
IdentityAggregationPolicy<T extends Message>	An aggregation policy that returns the original unmodified message as the aggregate.
MappingAggregationPolicy<S,T extends Message>	An aggregation policy that performs a simple map operation on the given message.
SinkAggregator<S extends Message,T extends Message>	This is a specific aggregator where the messsages implement the Message marker interface.