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 Object
implements TelemetryRegistry

Constructor Summary

Constructors

Constructor and Description
TelemetryRegistryImpl()

Method Summary

Modifier and Type	Method and Description
void	clearDispatchers()
Adapter	getAdapter(AdapterDefinition adapterDefinition)
Connector	getConnector(ConnectorDefinition connectorDefinition)
AsyncDispatcher<TelemetryMessage>	getDispatcher(String queueName)
Collection<AsyncDispatcher<TelemetryMessage>>	getDispatchers()
Listener	getListener(ListenerDefinition listenerDefinition)
com.codahale.metrics.MetricRegistry	getMetricRegistry()
Parser	getParser(ParserDefinition parserDefinition)
void	registerDispatcher(String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
void	removeDispatcher(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(String queueName,
                               AsyncDispatcher<TelemetryMessage> dispatcher)

Specified by:

registerDispatcher in interface TelemetryRegistry

clearDispatchers

public void clearDispatchers()

Specified by:

clearDispatchers in interface TelemetryRegistry

getDispatchers

public Collection<AsyncDispatcher<TelemetryMessage>> getDispatchers()

Specified by:

getDispatchers in interface TelemetryRegistry

getDispatcher

public AsyncDispatcher<TelemetryMessage> getDispatcher(String queueName)

Specified by:

getDispatcher in interface TelemetryRegistry

removeDispatcher

public void removeDispatcher(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)