org.opennms.core.ipc.sink.aggregation

Class AggregatingMessageProducer<S,T>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, MessageDispatcher<S>

Direct Known Subclasses:

AggregatingSinkMessageProducer

public abstract class AggregatingMessageProducer<S,T>
extends Object
implements MessageDispatcher<S>

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

Author:

jwhite

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
abstract void	dispatch(T message)
void	send(S message)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatingMessageProducer

public AggregatingMessageProducer(String id,
                                  AggregationPolicy<S,T> policy)

Method Detail

send

public void send(S message)

Specified by:

send in interface MessageDispatcher<S>

dispatch

public abstract void dispatch(T message)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception