public class TelemetryRegistryImpl extends Object implements TelemetryRegistry
Constructor and Description |
---|
TelemetryRegistryImpl() |
Modifier and Type | Method and Description |
---|---|
void |
clearDispatchers() |
Adapter |
getAdapter(AdapterDefinition adapterDefinition) |
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) |
public Adapter getAdapter(AdapterDefinition adapterDefinition)
getAdapter
in interface TelemetryRegistry
public Listener getListener(ListenerDefinition listenerDefinition)
getListener
in interface TelemetryRegistry
public Parser getParser(ParserDefinition parserDefinition)
getParser
in interface TelemetryRegistry
public void registerDispatcher(String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
registerDispatcher
in interface TelemetryRegistry
public void clearDispatchers()
clearDispatchers
in interface TelemetryRegistry
public Collection<AsyncDispatcher<TelemetryMessage>> getDispatchers()
getDispatchers
in interface TelemetryRegistry
public AsyncDispatcher<TelemetryMessage> getDispatcher(String queueName)
getDispatcher
in interface TelemetryRegistry
public void removeDispatcher(String queueName)
removeDispatcher
in interface TelemetryRegistry
public void setAdapterRegistryDelegate(TelemetryServiceRegistry<AdapterDefinition,Adapter> adapterRegistryDelegate)
public void setListenerRegistryDelegate(TelemetryServiceRegistry<ListenerDefinition,Listener> listenerRegistryDelegate)
public void setParserRegistryDelegate(TelemetryServiceRegistry<ParserDefinition,Parser> parserRegistryDelegate)
public com.codahale.metrics.MetricRegistry getMetricRegistry()
getMetricRegistry
in interface TelemetryRegistry
public void setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
Copyright © 2021. All rights reserved.