@Deprecated public class TurbineNonPersistentSchedulerService extends AbstractSchedulerService
services.SchedulerService.scheduler.jobs=scheduledJobName,scheduledJobName2 services.SchedulerService.scheduler.job.scheduledJobName.ID=1 services.SchedulerService.scheduler.job.scheduledJobName.SECOND=-1 services.SchedulerService.scheduler.job.scheduledJobName.MINUTE=-1 services.SchedulerService.scheduler.job.scheduledJobName.HOUR=7 services.SchedulerService.scheduler.job.scheduledJobName.WEEKDAY=-1 services.SchedulerService.scheduler.job.scheduledJobName.DAY_OF_MONTH=-1 services.SchedulerService.scheduler.job.scheduledJobName2.ID=1 services.SchedulerService.scheduler.job.scheduledJobName2.SECOND=-1 services.SchedulerService.scheduler.job.scheduledJobName2.MINUTE=-1 services.SchedulerService.scheduler.job.scheduledJobName2.HOUR=7 services.SchedulerService.scheduler.job.scheduledJobName2.WEEKDAY=-1 services.SchedulerService.scheduler.job.scheduledJobName2.DAY_OF_MONTH=-1Based on TamboraSchedulerService written by John Thorhauer.
AbstractSchedulerService.MainLoop
enabled, log, mainLoop, scheduleQueue, thread
configuration, name, serviceBroker
initableBroker, isInitialized
INTIALLY_ACTIVE, LOGGER_NAME, SERVICE_NAME
Constructor and Description |
---|
TurbineNonPersistentSchedulerService()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JobEntry |
getJob(int oid)
Deprecated.
This method returns the job element from the internal queue.
|
protected List<? extends JobEntry> |
loadJobs()
Deprecated.
Load all jobs from configuration storage
|
JobEntry |
newJob(int sec,
int min,
int hour,
int wd,
int day_mo,
String task)
Deprecated.
Factory method for a new Job
Schedule a job to run on a certain point of time.
|
void |
removeJob(JobEntry je)
Deprecated.
Remove a job from the queue.
|
void |
updateJob(JobEntry je)
Deprecated.
Add/update a job
|
addJob, clearThread, getThread, init, isEnabled, listJobs, nextJob, restart, setEnabled, shutdown, startScheduler, stopScheduler
init, init
getConfiguration, getName, getProperties, getServiceBroker, setName, setServiceBroker
getInit, getInitableBroker, setInit, setInitableBroker
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConfiguration, getName, getProperties, setName, setServiceBroker
getInit, init, setInitableBroker
public TurbineNonPersistentSchedulerService()
protected List<? extends JobEntry> loadJobs() throws TurbineException
AbstractSchedulerService
loadJobs
in class AbstractSchedulerService
TurbineException
- if jobs could not be loadedAbstractSchedulerService.loadJobs()
public JobEntry newJob(int sec, int min, int hour, int wd, int day_mo, String task) throws TurbineException
ScheduleService
newJob
in interface ScheduleService
newJob
in class AbstractSchedulerService
sec
- Value for entry "seconds".min
- Value for entry "minutes".hour
- Value for entry "hours".wd
- Value for entry "week days".day_mo
- Value for entry "month days".task
- Task to execute.TurbineException
- could not create jobScheduleService.newJob(int, int, int, int, int, java.lang.String)
public JobEntry getJob(int oid) throws TurbineException
getJob
in interface ScheduleService
getJob
in class AbstractSchedulerService
oid
- The int id for the job.TurbineException
- could not retrieve jobpublic void removeJob(JobEntry je)
removeJob
in interface ScheduleService
removeJob
in class AbstractSchedulerService
je
- A JobEntry with the job to remove.public void updateJob(JobEntry je) throws TurbineException
updateJob
in interface ScheduleService
updateJob
in class AbstractSchedulerService
je
- A JobEntry with the job to modifyTurbineException
- job could not be updatedCopyright © 2000–2019 The Apache Software Foundation. All rights reserved.