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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classAbstractCollectionAdapter
- Parameters:
messageLogEntry
- message to be converted into a collection setmessageLog
- 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 interfaceAdapter
- Overrides:
destroy
in classAbstractAdapter
-
-