Package 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:

java.lang.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	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 java.lang.AutoCloseable

close

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

send

Constructor Detail

AggregatingSinkMessageProducer

public AggregatingSinkMessageProducer(SinkModule<S,T> module)