public abstract class JobImpl extends Object implements Job
| Modifier and Type | Field and Description |
|---|---|
long | _idUnique job identifier |
| Constructor and Description |
|---|
JobImpl(RouterContext context)Create a new JobImpl. |
| Modifier and Type | Method and Description |
|---|---|
void | dropped()Default implementation does nothing. |
RouterContext | getContext()Get the router context that this job belongs to. |
long | getJobId()Get the unique job ID for this job. |
long | getMadeReadyOn()Get the timestamp when this job was last made ready for execution. |
JobTiming | getTiming()Get the timing object for this job. |
void | madeReady(long now)For JobQueue only, not for external use |
protected void | requeue(long delayMs)Requeue this job to run after the specified delay. |
String | toString() |
public JobImpl(RouterContext context)
public void dropped()
public final RouterContext getContext()
public long getJobId()
public long getMadeReadyOn()
public JobTiming getTiming()
public void madeReady(long now)
now - the current time in millisecondsprotected void requeue(long delayMs)
delayMs - the delay in milliseconds before the job should run again