Package org.opennms.netmgt.telemetry.protocols.jti.adapter

Class JtiGpbAdapter

java.lang.Object

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

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

org.opennms.netmgt.telemetry.protocols.collection.AbstractScriptedCollectionAdapter

org.opennms.netmgt.telemetry.protocols.jti.adapter.JtiGpbAdapter

All Implemented Interfaces:

Adapter

public class JtiGpbAdapter
extends AbstractScriptedCollectionAdapter

An adapter for handling Junos Telemetry Interface packets. Messages are decoded using the corresponding classes generated by the Google Protobuf definitions and forwarded to a script for further processing.

Author:

jwhite

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
JtiGpbAdapter(AdapterDefinition adapterConfig, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
java.util.stream.Stream<CollectionSetWithAgent>	handleCollectionMessage(TelemetryMessageLogEntry message, TelemetryMessageLog messageLog)	Build a collection set from the given message.
void	setCollectionAgentFactory(CollectionAgentFactory collectionAgentFactory)
void	setInterfaceToNodeCache(InterfaceToNodeCache interfaceToNodeCache)
void	setNodeDao(NodeDao nodeDao)
void	setTransactionTemplate(org.springframework.transaction.support.TransactionOperations transactionTemplate)

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

destroy, getCollectionBuilder, getScript, setScript

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

JtiGpbAdapter

public JtiGpbAdapter(AdapterDefinition adapterConfig,
                     com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

handleCollectionMessage

public java.util.stream.Stream<CollectionSetWithAgent> handleCollectionMessage(TelemetryMessageLogEntry message,
                                                                               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:

message - 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)

setNodeDao

public void setNodeDao(NodeDao nodeDao)

setTransactionTemplate

public void setTransactionTemplate(org.springframework.transaction.support.TransactionOperations transactionTemplate)