Uses of Class
org.opennms.core.ipc.sink.aggregation.AggregatingMessageProducer

Packages that use AggregatingMessageProducer

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

Uses of AggregatingMessageProducer in org.opennms.core.ipc.sink.aggregation

Subclasses of AggregatingMessageProducer in org.opennms.core.ipc.sink.aggregation

Modifier and Type	Class and Description
class	AggregatingSinkMessageProducer<S extends Message,T extends Message> A MessageDispatcher that applies the SinkModule's AggregationPolicy using the Aggregator.

Constructors in org.opennms.core.ipc.sink.aggregation with parameters of type AggregatingMessageProducer

Constructor and Description
Aggregator(String id, AggregationPolicy<S,T,?> policy, AggregatingMessageProducer<S,T> messageProducer)