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) |
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 |
setParserRegistryDelegate(TelemetryServiceRegistry<ParserDefinition,Parser> parserRegistryDelegate) |
public Adapter getAdapter(AdapterDefinition adapterDefinition)
getAdapter in interface TelemetryRegistrypublic Listener getListener(ListenerDefinition listenerDefinition)
getListener in interface TelemetryRegistrypublic Parser getParser(ParserDefinition parserDefinition)
getParser in interface TelemetryRegistrypublic void registerDispatcher(String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
registerDispatcher in interface TelemetryRegistrypublic void clearDispatchers()
clearDispatchers in interface TelemetryRegistrypublic Collection<AsyncDispatcher<TelemetryMessage>> getDispatchers()
getDispatchers in interface TelemetryRegistrypublic AsyncDispatcher<TelemetryMessage> getDispatcher(String queueName)
getDispatcher in interface TelemetryRegistrypublic void removeDispatcher(String queueName)
removeDispatcher in interface TelemetryRegistrypublic void setAdapterRegistryDelegate(TelemetryServiceRegistry<AdapterDefinition,Adapter> adapterRegistryDelegate)
public void setListenerRegistryDelegate(TelemetryServiceRegistry<ListenerDefinition,Listener> listenerRegistryDelegate)
public void setParserRegistryDelegate(TelemetryServiceRegistry<ParserDefinition,Parser> parserRegistryDelegate)
Copyright © 2019. All rights reserved.