Package org.opennms.core.ipc.sink.aggregation
-
Class Summary Class Description AggregatingMessageProducer<S,T> AggregatingSinkMessageProducer<S extends Message,T extends Message> Aggregator<S,T> This aggregator is used to realize a givenAggregationPolicy
.ArrayListAggregationPolicy<S> An aggregation policy that createsArrayList
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 theMessage
marker interface.