org.opennms.netmgt.telemetry.protocols.bmp.adapter

Class BmpTelemetryAdapter

java.lang.Object

org.opennms.netmgt.telemetry.protocols.collection.AbstractAdapter

org.opennms.netmgt.telemetry.protocols.collection.AbstractCollectionAdapter

org.opennms.netmgt.telemetry.protocols.bmp.adapter.BmpTelemetryAdapter

All Implemented Interfaces:

Adapter

public class BmpTelemetryAdapter
extends AbstractCollectionAdapter

Field Summary

Fields inherited from class org.opennms.netmgt.telemetry.protocols.collection.AbstractCollectionAdapter

bundleContext

Fields inherited from class org.opennms.netmgt.telemetry.protocols.collection.AbstractAdapter

adapterConfig, logParsingTimer, packetsPerLogHistogram

Constructor Summary

Constructors

Constructor and Description
BmpTelemetryAdapter(AdapterDefinition adapterConfig, com.codahale.metrics.MetricRegistry metricRegistry, NodeDao nodeDao, org.springframework.transaction.support.TransactionTemplate transactionTemplate)

Method Summary

Modifier and Type	Method and Description
String	getMetaDataNodeLookup()
java.util.stream.Stream<CollectionSetWithAgent>	handleCollectionMessage(TelemetryMessageLogEntry messageLogEntry, TelemetryMessageLog messageLog) Build a collection set from the given message.
void	setCollectionAgentFactory(CollectionAgentFactory collectionAgentFactory)
void	setInterfaceToNodeCache(InterfaceToNodeCache interfaceToNodeCache)
void	setMetaDataNodeLookup(String metaDataNodeLookup)

Methods inherited from class org.opennms.netmgt.telemetry.protocols.collection.AbstractCollectionAdapter

getThresholdingService, handleMessage, setBundleContext, setFilterDao, setPersisterFactory, setThresholdingService

Methods inherited from class org.opennms.netmgt.telemetry.protocols.collection.AbstractAdapter

destroy, handleMessageLog

Methods inherited from class java.lang.Object

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

Constructor Detail

BmpTelemetryAdapter

public BmpTelemetryAdapter(AdapterDefinition adapterConfig,
                           com.codahale.metrics.MetricRegistry metricRegistry,
                           NodeDao nodeDao,
                           org.springframework.transaction.support.TransactionTemplate transactionTemplate)

Method Detail

handleCollectionMessage

public java.util.stream.Stream<CollectionSetWithAgent> handleCollectionMessage(TelemetryMessageLogEntry messageLogEntry,
                                                                               TelemetryMessageLog messageLog)

Description copied from class: AbstractCollectionAdapter

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.

Specified by:

handleCollectionMessage in class AbstractCollectionAdapter

Parameters:

messageLogEntry - 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

setCollectionAgentFactory

public void setCollectionAgentFactory(CollectionAgentFactory collectionAgentFactory)

setInterfaceToNodeCache

public void setInterfaceToNodeCache(InterfaceToNodeCache interfaceToNodeCache)

getMetaDataNodeLookup

public String getMetaDataNodeLookup()

setMetaDataNodeLookup

public void setMetaDataNodeLookup(String metaDataNodeLookup)