Interface TelemetryRegistry
-
- All Known Implementing Classes:
TelemetryRegistryImpl
public interface TelemetryRegistry
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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)
-
-
-
Method Detail
-
getAdapter
Adapter getAdapter(AdapterDefinition adapterDefinition)
-
getListener
Listener getListener(ListenerDefinition listenerDefinition)
-
getConnector
Connector getConnector(ConnectorDefinition connectorDefinition)
-
getParser
Parser getParser(ParserDefinition parserDefinition)
-
registerDispatcher
void registerDispatcher(java.lang.String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
-
clearDispatchers
void clearDispatchers()
-
removeDispatcher
void removeDispatcher(java.lang.String queueName)
-
getDispatchers
java.util.Collection<AsyncDispatcher<TelemetryMessage>> getDispatchers()
-
getDispatcher
AsyncDispatcher<TelemetryMessage> getDispatcher(java.lang.String queueName)
-
getMetricRegistry
com.codahale.metrics.MetricRegistry getMetricRegistry()
-
-