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

Class BmpIntegrationAdapter

java.lang.Object

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

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

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

All Implemented Interfaces:

Adapter

public class BmpIntegrationAdapter
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	Description
BmpIntegrationAdapter(AdapterDefinition adapterConfig, com.codahale.metrics.MetricRegistry metricRegistry, BmpMessageHandler messageHandler)

Method Summary

Modifier and Type	Method	Description
void	destroy()
java.util.stream.Stream<CollectionSetWithAgent>	handleCollectionMessage(TelemetryMessageLogEntry messageLogEntry, TelemetryMessageLog messageLog)	Build a collection set from the given message.

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

handleMessageLog

Methods inherited from class java.lang.Object

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

Constructor Detail

BmpIntegrationAdapter

public BmpIntegrationAdapter(AdapterDefinition adapterConfig,
                             com.codahale.metrics.MetricRegistry metricRegistry,
                             BmpMessageHandler messageHandler)

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

destroy

public void destroy()

Specified by:

destroy in interface Adapter

Overrides:

destroy in class AbstractAdapter