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

Class SinkAggregator<S extends Message,T extends Message>

java.lang.Object

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

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

Type Parameters:

S - individual message

T - aggregated message (i.e. bucket)

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable

public class SinkAggregator<S extends Message,T extends Message>
extends Aggregator<S,T>

This is a specific aggregator where the messsages implement the Message marker interface.

Author:

jwhite

Nested Class Summary

Nested classes/interfaces inherited from class org.opennms.core.ipc.sink.aggregation.Aggregator

Aggregator.Bucket

Field Summary

Fields inherited from class org.opennms.core.ipc.sink.aggregation.Aggregator

DEFAULT_NUM_STRIPE_LOCKS, NUM_STRIPE_LOCKS_SYS_PROP

Constructor Summary

Constructors

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

Method Summary

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

aggregate, close, run

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkAggregator

public SinkAggregator(SinkModule<S,T> module,
                      AggregatingSinkMessageProducer<S,T> messageProducer)