J - a specialized job entry typepublic class JobQueue<J extends JobEntry> extends Object
| Constructor and Description |
|---|
JobQueue()
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
add(J je)
Add a job to the queue.
|
void |
batchLoad(List<J> jobEntries)
Batch load jobs.
|
J |
getJob(J je)
Return a specific job.
|
J |
getNext()
Return the next job off the top of the queue, or
null if
there are no jobs in the queue. |
Vector<J> |
list()
List jobs in the queue.
|
void |
modify(J je)
Modify a job on the queue.
|
void |
remove(J je)
Remove a job from the queue.
|
void |
updateQueue(J je)
Update the job for its next run time.
|
public J getNext()
null if
there are no jobs in the queue.public J getJob(J je)
je - The JobEntry we are looking for.public Vector<J> list()
JobEntry objects.public void add(J je)
je - A JobEntry job.public void batchLoad(List<J> jobEntries)
SchedulerService start-up.jobEntries - A list of the JobEntry objects to load.public void remove(J je)
je - A JobEntry with the job to remove.public void modify(J je) throws TurbineException
je - A JobEntry with the job to modifyTurbineException - if the runtime calculation failspublic void updateQueue(J je) throws TurbineException
je - A JobEntry to be updated.TurbineException - a generic exception.Copyright © 2000–2019 The Apache Software Foundation. All rights reserved.