org.opennms.core.ipc.sink.aggregation

Class AggregatingSinkMessageProducer<S extends Message,T extends Message>

java.lang.Object

org.opennms.core.ipc.sink.aggregation.AggregatingMessageProducer<S,T>

org.opennms.core.ipc.sink.aggregation.AggregatingSinkMessageProducer<S,T>

All Implemented Interfaces:

AutoCloseable, MessageDispatcher<S>, SyncDispatcher<S>

public abstract class AggregatingSinkMessageProducer<S extends Message,T extends Message>
extends AggregatingMessageProducer<S,T>
implements SyncDispatcher<S>

A MessageDispatcher that applies the SinkModule's AggregationPolicy using the Aggregator.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
AggregatingSinkMessageProducer(SinkModule<S,T> module)

Method Summary

Methods inherited from class org.opennms.core.ipc.sink.aggregation.AggregatingMessageProducer

close, dispatch, send

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opennms.core.ipc.sink.api.MessageDispatcher

send

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

AggregatingSinkMessageProducer

public AggregatingSinkMessageProducer(SinkModule<S,T> module)