org.opennms.netmgt.telemetry.adapters.jti

Class JtiGpbAdapter

java.lang.Object

org.opennms.netmgt.telemetry.adapters.collection.AbstractPersistingAdapter

org.opennms.netmgt.telemetry.adapters.jti.JtiGpbAdapter

All Implemented Interfaces:

Adapter

public class JtiGpbAdapter
extends AbstractPersistingAdapter

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

Constructor Summary

Constructors

Constructor and Description
JtiGpbAdapter()

Method Summary

Modifier and Type	Method and Description
String	getScript()
Optional<CollectionSetWithAgent>	handleMessage(TelemetryMessageDTO message, TelemetryMessageLogDTO messageLog) Build a collection set from the given message.
void	setScript(String script)

Methods inherited from class org.opennms.netmgt.telemetry.adapters.collection.AbstractPersistingAdapter

handleMessageLog, setProtocol

Methods inherited from class java.lang.Object

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

Constructor Detail

JtiGpbAdapter

public JtiGpbAdapter()

Method Detail

handleMessage

public Optional<CollectionSetWithAgent> handleMessage(TelemetryMessageDTO message,
                                                      TelemetryMessageLogDTO messageLog)
                                               throws Exception

Description copied from class: AbstractPersistingAdapter

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:

handleMessage in class AbstractPersistingAdapter

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

Throws:

Exception - if an error occured while generating the collection set

getScript

public String getScript()

setScript

public void setScript(String script)