org.opennms.netmgt.trapd

Class TrapSinkModule

java.lang.Object

org.opennms.core.ipc.sink.xml.AbstractXmlSinkModule<TrapInformationWrapper,TrapLogDTO>

org.opennms.netmgt.trapd.TrapSinkModule

All Implemented Interfaces:

SinkModule<TrapInformationWrapper,TrapLogDTO>

public class TrapSinkModule
extends AbstractXmlSinkModule<TrapInformationWrapper,TrapLogDTO>

Constructor Summary

Constructors

Constructor and Description
TrapSinkModule(TrapdConfig trapdConfig, OnmsDistPoller distPoller)

Method Summary

Modifier and Type	Method and Description
AggregationPolicy<TrapInformationWrapper,TrapLogDTO>	getAggregationPolicy() Defines how messages should be combined, and when they should be "released".
AsyncPolicy	getAsyncPolicy() Defines how messages should be asynchronously dispatched.
String	getId() Globally unique identifier.
int	getNumConsumerThreads() The number of threads used to consume from the broker.

Methods inherited from class org.opennms.core.ipc.sink.xml.AbstractXmlSinkModule

equals, hashCode, marshal, unmarshal

Methods inherited from class java.lang.Object

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

Constructor Detail

TrapSinkModule

public TrapSinkModule(TrapdConfig trapdConfig,
                      OnmsDistPoller distPoller)

Method Detail

getId

public String getId()

Description copied from interface: SinkModule

Globally unique identifier. Used in the JMS queue name in the Camel implementation.

getNumConsumerThreads

public int getNumConsumerThreads()

Description copied from interface: SinkModule

The number of threads used to consume from the broker.

getAggregationPolicy

public AggregationPolicy<TrapInformationWrapper,TrapLogDTO> getAggregationPolicy()

Description copied from interface: SinkModule

Defines how messages should be combined, and when they should be "released". Modules that do not wish to use aggregation can return null.

Returns:

the AggregationPolicy used to combine messages, or null if the messages should not be combined.

getAsyncPolicy

public AsyncPolicy getAsyncPolicy()

Description copied from interface: SinkModule

Defines how messages should be asynchronously dispatched.

Returns:

the AsyncPolicy used when asynchronously dispatching messages for this module.