Class LockingJob

  • All Implemented Interfaces:
    org.quartz.Job

    public class LockingJob
    extends Object
    implements org.quartz.Job
    This Heartbeat job collects data and passes it to the HBDataSenderService. Collectors using this job will collect data in one cluster node per execution, this is achieved by a job lock on collector id. The job lock is obtained by the first repository node which requests it for its collector id.
    • Constructor Detail

      • LockingJob

        public LockingJob()
    • Method Detail

      • execute

        public void execute​(org.quartz.JobExecutionContext jobexecutioncontext)
                     throws org.quartz.JobExecutionException
        Specified by:
        execute in interface org.quartz.Job
        Throws:
        org.quartz.JobExecutionException