public class SingleSubscriptionManager extends AbstractSubscriptionManager
Modifier and Type | Class and Description |
---|---|
static interface |
SingleSubscriptionManager.Listener |
cache, started
Constructor and Description |
---|
SingleSubscriptionManager(ScheduledExecutorService executor,
HiveSource hiveSource,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(String itemId,
SingleSubscriptionManager.Listener listener) |
protected void |
putState(String itemId,
DataItemValue value) |
void |
removeListener(String itemId,
SingleSubscriptionManager.Listener listener) |
bind, clearCache, getCacheCopy, getCacheValue, handleCreateSessionResult, handleDataChanged, handleSubscriptionChanged, performSetHive, start, stop, subscribe, subscribeAll, unbind, unsubscribe, writeAttributes, writeValue
public SingleSubscriptionManager(ScheduledExecutorService executor, HiveSource hiveSource, Properties properties)
protected void putState(String itemId, DataItemValue value)
putState
in class AbstractSubscriptionManager
public void addListener(String itemId, SingleSubscriptionManager.Listener listener)
public void removeListener(String itemId, SingleSubscriptionManager.Listener listener)