Class CheckTopologyTask
- java.lang.Object
-
- org.apache.sling.event.impl.jobs.tasks.CheckTopologyTask
-
public class CheckTopologyTask extends Object
The check topology task checks for changes in the topology and queue configuration and reassigns jobs. If the leader instance finds a dead instance it reassigns its jobs to live instances. The leader instance also checks for unassigned jobs and tries to assign them. If an instance detects jobs which it doesn't process anymore it reassigns them as well.
-
-
Constructor Summary
Constructors Constructor Description CheckTopologyTask(JobManagerConfiguration config)
Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
assignUnassignedJobs()
Try to assign unassigned jobs as there might be changes in: - queue configurations - topology - capabilitiesvoid
fullRun()
One maintenance run
-
-
-
Constructor Detail
-
CheckTopologyTask
public CheckTopologyTask(JobManagerConfiguration config)
Constructor- Parameters:
config
- The configuration
-
-