Class LockingJob

  • All Implemented Interfaces:
    org.quartz.Job

    public class LockingJob
    extends java.lang.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 Summary

      Constructors 
      Constructor Description
      LockingJob()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void execute​(org.quartz.JobExecutionContext jobexecutioncontext)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • DATA_SENDER_SERVICE_KEY

        public static final java.lang.String DATA_SENDER_SERVICE_KEY
        See Also:
        Constant Field Values
      • JOB_LOCK_SERVICE_KEY

        public static final java.lang.String JOB_LOCK_SERVICE_KEY
        See Also:
        Constant Field Values
    • 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