Package org.opennms.netmgt.telemetry.protocols.registry.impl

Class TelemetryRegistryImpl

java.lang.Object

org.opennms.netmgt.telemetry.protocols.registry.impl.TelemetryRegistryImpl

All Implemented Interfaces:

TelemetryRegistry

public class TelemetryRegistryImpl
extends java.lang.Object
implements TelemetryRegistry

Constructor Summary

Constructors

Constructor	Description
TelemetryRegistryImpl()

Method Summary

Modifier and Type	Method	Description
void	clearDispatchers()
Adapter	getAdapter(AdapterDefinition adapterDefinition)
Connector	getConnector(ConnectorDefinition connectorDefinition)
AsyncDispatcher<TelemetryMessage>	getDispatcher(java.lang.String queueName)
java.util.Collection<AsyncDispatcher<TelemetryMessage>>	getDispatchers()
Listener	getListener(ListenerDefinition listenerDefinition)
com.codahale.metrics.MetricRegistry	getMetricRegistry()
Parser	getParser(ParserDefinition parserDefinition)
void	registerDispatcher(java.lang.String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
void	removeDispatcher(java.lang.String queueName)
void	setAdapterRegistryDelegate(TelemetryServiceRegistry<AdapterDefinition,Adapter> adapterRegistryDelegate)
void	setListenerRegistryDelegate(TelemetryServiceRegistry<ListenerDefinition,Listener> listenerRegistryDelegate)
void	setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
void	setParserRegistryDelegate(TelemetryServiceRegistry<ParserDefinition,Parser> parserRegistryDelegate)

Methods inherited from class java.lang.Object

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

Constructor Detail

TelemetryRegistryImpl

public TelemetryRegistryImpl()

Method Detail

getAdapter

public Adapter getAdapter(AdapterDefinition adapterDefinition)

Specified by:

getAdapter in interface TelemetryRegistry

getListener

public Listener getListener(ListenerDefinition listenerDefinition)

Specified by:

getListener in interface TelemetryRegistry

getConnector

public Connector getConnector(ConnectorDefinition connectorDefinition)

Specified by:

getConnector in interface TelemetryRegistry

getParser

public Parser getParser(ParserDefinition parserDefinition)

Specified by:

getParser in interface TelemetryRegistry

registerDispatcher

public void registerDispatcher(java.lang.String queueName,
                               AsyncDispatcher<TelemetryMessage> dispatcher)

Specified by:

registerDispatcher in interface TelemetryRegistry

clearDispatchers

public void clearDispatchers()

Specified by:

clearDispatchers in interface TelemetryRegistry

getDispatchers

public java.util.Collection<AsyncDispatcher<TelemetryMessage>> getDispatchers()

Specified by:

getDispatchers in interface TelemetryRegistry

getDispatcher

public AsyncDispatcher<TelemetryMessage> getDispatcher(java.lang.String queueName)

Specified by:

getDispatcher in interface TelemetryRegistry

removeDispatcher

public void removeDispatcher(java.lang.String queueName)

Specified by:

removeDispatcher in interface TelemetryRegistry

setAdapterRegistryDelegate

public void setAdapterRegistryDelegate(TelemetryServiceRegistry<AdapterDefinition,Adapter> adapterRegistryDelegate)

setListenerRegistryDelegate

public void setListenerRegistryDelegate(TelemetryServiceRegistry<ListenerDefinition,Listener> listenerRegistryDelegate)

setParserRegistryDelegate

public void setParserRegistryDelegate(TelemetryServiceRegistry<ParserDefinition,Parser> parserRegistryDelegate)

getMetricRegistry

public com.codahale.metrics.MetricRegistry getMetricRegistry()

Specified by:

getMetricRegistry in interface TelemetryRegistry

setMetricRegistry

public void setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)