@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 - 2020 Adobe. All Rights Reserved