org.opennms.netmgt.telemetry.adapters.netflow

Class AbstractAdapter<P>

java.lang.Object

org.opennms.netmgt.telemetry.adapters.netflow.AbstractAdapter<P>

All Implemented Interfaces:

Adapter

Direct Known Subclasses:

IpfixAdapter, Netflow5Adapter, Netflow9Adapter, SFlowAdapter

public abstract class AbstractAdapter<P>
extends Object
implements Adapter

Constructor Summary

Constructors

Constructor and Description
AbstractAdapter(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(TelemetryMessage message)
void	setProtocol(Protocol protocol) A single instance of an adapter will only be responsible for one protocol.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractAdapter

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

Method Detail

setProtocol

public void setProtocol(Protocol protocol)

Description copied from interface: Adapter

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

Specified by:

setProtocol in interface Adapter

Parameters:

protocol - the protocol 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(TelemetryMessage message)

destroy

public void destroy()

Specified by:

destroy in interface Adapter