org.apache.sling.event.impl.jobs
Class TopologyCapabilities

java.lang.Object
  extended by org.apache.sling.event.impl.jobs.TopologyCapabilities

public class TopologyCapabilities
extends Object

The capabilities of a topology.


Nested Class Summary
static class TopologyCapabilities.InstanceDescriptionComparator
           
 
Field Summary
static String PROPERTY_TOPICS
           
 
Constructor Summary
TopologyCapabilities(org.apache.sling.discovery.TopologyView view, boolean disableDistribution)
           
 
Method Summary
 void deactivate()
           
 String detectTarget(String jobTopic, Map<String,Object> jobProperties, QueueConfigurationManager.QueueInfo queueInfo)
          Detect the target instance.
static Map<String,String> getAllInstancesMap(org.apache.sling.discovery.TopologyView view)
           
 long getChangeCount()
           
 Map<String,List<org.apache.sling.discovery.InstanceDescription>> getInstanceCapabilities()
           
 List<org.apache.sling.discovery.InstanceDescription> getPotentialTargets(String jobTopic, Map<String,Object> jobProperties)
          Return the potential targets (Sling IDs) sorted by ID
 boolean isActive()
           
 boolean isActive(String instanceId)
           
 boolean isLeader()
          Is the current instance the leader?
 boolean isSame(Map<String,String> newAllInstancesMap)
           
 void update(boolean disableDistribution2)
          Update the configuration
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

PROPERTY_TOPICS

public static final String PROPERTY_TOPICS
See Also:
Constant Field Values
Constructor Detail

TopologyCapabilities

public TopologyCapabilities(org.apache.sling.discovery.TopologyView view,
                            boolean disableDistribution)
Method Detail

getAllInstancesMap

public static Map<String,String> getAllInstancesMap(org.apache.sling.discovery.TopologyView view)

update

public void update(boolean disableDistribution2)
Update the configuration


isSame

public boolean isSame(Map<String,String> newAllInstancesMap)

deactivate

public void deactivate()

isActive

public boolean isActive()

getChangeCount

public long getChangeCount()

isActive

public boolean isActive(String instanceId)

isLeader

public boolean isLeader()
Is the current instance the leader?


getPotentialTargets

public List<org.apache.sling.discovery.InstanceDescription> getPotentialTargets(String jobTopic,
                                                                                Map<String,Object> jobProperties)
Return the potential targets (Sling IDs) sorted by ID


detectTarget

public String detectTarget(String jobTopic,
                           Map<String,Object> jobProperties,
                           QueueConfigurationManager.QueueInfo queueInfo)
Detect the target instance.


getInstanceCapabilities

public Map<String,List<org.apache.sling.discovery.InstanceDescription>> getInstanceCapabilities()


Copyright © 2007-2013 The Apache Software Foundation. All Rights Reserved.