org.opennms.netmgt.telemetry.protocols.flows

Class AbstractFlowAdapter<P>

java.lang.Object

org.opennms.netmgt.telemetry.protocols.flows.AbstractFlowAdapter<P>

All Implemented Interfaces:

Adapter

Direct Known Subclasses:

NetflowAdapter, SFlowAdapter

public abstract class AbstractFlowAdapter<P>
extends Object
implements Adapter

Constructor Summary

Constructors

Constructor and Description
AbstractFlowAdapter(AdapterDefinition adapterConfig, com.codahale.metrics.MetricRegistry metricRegistry, FlowRepository flowRepository, Converter<P> converter)

Method Summary

Modifier and Type	Method and Description
void	destroy()
String	getMetaDataNodeLookup()
void	handleMessageLog(TelemetryMessageLog messageLog) Handle the messages.
protected abstract P	parse(TelemetryMessageLogEntry message)
void	setMetaDataNodeLookup(String metaDataNodeLookup)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFlowAdapter

public AbstractFlowAdapter(AdapterDefinition adapterConfig,
                           com.codahale.metrics.MetricRegistry metricRegistry,
                           FlowRepository flowRepository,
                           Converter<P> converter)

Method Detail

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

parse

protected abstract P parse(TelemetryMessageLogEntry message)

destroy

public void destroy()

Specified by:

destroy in interface Adapter

getMetaDataNodeLookup

public String getMetaDataNodeLookup()

setMetaDataNodeLookup

public void setMetaDataNodeLookup(String metaDataNodeLookup)