@Deprecated
public interface OffloadingTopicManager
OffloadingTopicManager manages instance blacklisting / whitelisting for specific topics. Furthermore, it provides a
view of the instances grouped by topic.
Clients outside offloading must not use this interface.| Modifier and Type | Method and Description |
|---|---|
void |
configureInstance(java.lang.String slingID,
java.util.Map<TopicConfigurationAction,java.util.Set<java.lang.String>> configuration)
Deprecated.
Configures the topics an instance will process using a configuration map structured in the following way:
|
java.util.Set<java.lang.String> |
getBlacklistedTopics(InstanceDescription instance)
Deprecated.
Retrieves the blacklisted topics from an instance.
|
java.util.Map<java.lang.String,TopicInstancesHolder> |
getInstances()
Deprecated.
Provides a
Map view of all the instances from the topology. |
java.util.Set<java.lang.String> |
getRegisteredTopics(InstanceDescription instance)
Deprecated.
Retrieves the topics registered for processing from an instance.
|
java.util.Set<java.lang.String> |
getWhitelistedTopics(InstanceDescription instance)
Deprecated.
Retrieves the whitelisted topics from an instance.
|
java.util.Map<java.lang.String,TopicInstancesHolder> getInstances()
Map view of all the instances from the topology.void configureInstance(java.lang.String slingID,
java.util.Map<TopicConfigurationAction,java.util.Set<java.lang.String>> configuration)
Configures the topics an instance will process using a configuration map structured in the following way:
key - one of: exclusive, enable, disable (for more details see
TopicConfigurationAction
value - a set of topic strings
The topics marked as exclusive will be added to the exclusive whitelist. The topics marked otherwise will just be added /
removed from the blacklist.
slingID - the slingID of the instance to be configuredconfiguration - a configuration map.OffloadingException - if the configuration operation failsjava.util.Set<java.lang.String> getRegisteredTopics(InstanceDescription instance)
instance - the instancejava.util.Set<java.lang.String> getWhitelistedTopics(InstanceDescription instance)
instance - the instancejava.util.Set<java.lang.String> getBlacklistedTopics(InstanceDescription instance)
instance - the instanceCopyright © 2010 - 2023 Adobe. All Rights Reserved