org.opennms.netmgt.telemetry.protocols.collection

Class AbstractPersistingAdapter

java.lang.Object

org.opennms.netmgt.telemetry.protocols.collection.AbstractPersistingAdapter

All Implemented Interfaces:

Adapter

Direct Known Subclasses:

JtiGpbAdapter, NxosGpbAdapter, SFlowTelemetryAdapter

public abstract class AbstractPersistingAdapter
extends Object
implements Adapter

Constructor Summary

Constructors

Constructor and Description
AbstractPersistingAdapter(String name, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
void	destroy()
protected ScriptedCollectionSetBuilder	getCollectionBuilder()
String	getScript()
ThresholdingService	getThresholdingService()
abstract java.util.stream.Stream<CollectionSetWithAgent>	handleMessage(TelemetryMessageLogEntry message, TelemetryMessageLog messageLog) Build a collection set from the given message.
void	handleMessageLog(TelemetryMessageLog messageLog) Handle the messages.
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setConfig(AdapterDefinition adapterConfig) A single instance of an adapter will only be responsible for one config.
void	setFilterDao(FilterDao filterDao)
void	setPersisterFactory(PersisterFactory persisterFactory)
void	setScript(String script)
void	setThresholdingService(ThresholdingService thresholdingService)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPersistingAdapter

public AbstractPersistingAdapter(String name,
                                 com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

handleMessage

public abstract java.util.stream.Stream<CollectionSetWithAgent> handleMessage(TelemetryMessageLogEntry message,
                                                                              TelemetryMessageLog messageLog)

Build a collection set from the given message. The message log is also provided in case the log contains additional meta-data required. IMPORTANT: Implementations of this method must be thread-safe.

Parameters:

message - message to be converted into a collection set

messageLog - message log to which the message belongs

Returns:

a CollectionSetWithAgent or an empty value if nothing should be persisted

Throws:

Exception - if an error occured while generating the collection set

handleMessageLog

public void handleMessageLog(TelemetryMessageLog messageLog)

Description copied from interface: Adapter

Handle the messages. IMPORTANT: Implementations of this method MUST be thread-safe.

Specified by:

handleMessageLog in interface Adapter

Parameters:

messageLog - group of messages to be handled

setConfig

public void setConfig(AdapterDefinition adapterConfig)

Description copied from interface: Adapter

A single instance of an adapter will only be responsible for one config. The config will be set using this method before any calls to Adapter.handleMessageLog(org.opennms.netmgt.telemetry.api.adapter.TelemetryMessageLog) are made.

Specified by:

setConfig in interface Adapter

Parameters:

adapterConfig - the config in which the adapter is defined

setFilterDao

public void setFilterDao(FilterDao filterDao)

setPersisterFactory

public void setPersisterFactory(PersisterFactory persisterFactory)

getThresholdingService

public ThresholdingService getThresholdingService()

setThresholdingService

public void setThresholdingService(ThresholdingService thresholdingService)

getCollectionBuilder

protected ScriptedCollectionSetBuilder getCollectionBuilder()

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

getScript

public String getScript()

setScript

public void setScript(String script)

destroy

public void destroy()

Specified by:

destroy in interface Adapter