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:

IpfixAdapter, Netflow5Adapter, Netflow9Adapter, SFlowAdapter

public abstract class AbstractFlowAdapter<P>
extends Object
implements Adapter

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	handleMessageLog(TelemetryMessageLog messageLog) Handle the messages.
protected abstract P	parse(TelemetryMessageLogEntry message)
void	setConfig(AdapterDefinition protocol) A single instance of an adapter will only be responsible for one config.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFlowAdapter

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

Method Detail

setConfig

public void setConfig(AdapterDefinition protocol)

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:

protocol - the config in which the adapter is defined

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