Class JobImpl

    • Method Detail

      • getJobId

        public long getJobId()
        Description copied from interface: Job
        unique id
        Specified by:
        getJobId in interface Job
      • getTiming

        public JobTiming getTiming()
        Description copied from interface: Job
        Timing criteria for the task
        Specified by:
        getTiming in interface Job
      • getMadeReadyOn

        public long getMadeReadyOn()
      • madeReady

        public void madeReady()
      • dropped

        public void dropped()
        Description copied from interface: Job
        the router is extremely overloaded, so this job has been dropped. if for some reason the job *must* do some cleanup / requeueing of other tasks, it should do so here.
        Specified by:
        dropped in interface Job
      • requeue

        protected void requeue​(long delayMs)
        Warning - only call this from runJob() or if Job is not already queued, or else it gets the job queue out of order.