public abstract class AbstractPersistingAdapter extends Object implements Adapter
Constructor and Description |
---|
AbstractPersistingAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected ScriptedCollectionSetBuilder |
getCollectionBuilder() |
String |
getScript() |
abstract java.util.stream.Stream<CollectionSetWithAgent> |
handleMessage(TelemetryMessage message,
TelemetryMessageLog messageLog)
Build a collection set from the given message.
|
void |
handleMessageLog(TelemetryMessageLog messageLog)
Handle the messages.
|
void |
setBundleContext(org.osgi.framework.BundleContext bundleContext) |
void |
setFilterDao(FilterDao filterDao) |
void |
setPersisterFactory(PersisterFactory persisterFactory) |
void |
setProtocol(Protocol protocol)
A single instance of an adapter will only be responsible
for one protocol.
|
void |
setScript(String script) |
public abstract java.util.stream.Stream<CollectionSetWithAgent> handleMessage(TelemetryMessage message, TelemetryMessageLog messageLog)
message
- message to be converted into a collection setmessageLog
- message log to which the message belongsCollectionSetWithAgent
or an empty value if nothing
should be persistedException
- if an error occured while generating the collection setpublic void handleMessageLog(TelemetryMessageLog messageLog)
Adapter
handleMessageLog
in interface Adapter
messageLog
- group of messages to be handledpublic void setProtocol(Protocol protocol)
Adapter
Adapter.handleMessageLog(org.opennms.netmgt.telemetry.adapters.api.TelemetryMessageLog)
are made.setProtocol
in interface Adapter
protocol
- the protocol in which the adapter is definedpublic void setFilterDao(FilterDao filterDao)
public void setPersisterFactory(PersisterFactory persisterFactory)
protected ScriptedCollectionSetBuilder getCollectionBuilder() throws Exception
Exception
public void setBundleContext(org.osgi.framework.BundleContext bundleContext)
public String getScript()
public void setScript(String script)
Copyright © 2018. All rights reserved.