public interface Scheduler
Modifier and Type | Interface and Description |
---|---|
static class |
Scheduler.JobDetails |
static class |
Scheduler.JobInfo
Wrapper containing information about a scheduled job.
|
static interface |
Scheduler.JobProcessor
Interface implemented by the object responsible for job execution.
|
static class |
Scheduler.JobProcessorException
Exception thrown by the
Scheduler.JobProcessor to indicate failure in job
processing. |
static class |
Scheduler.JobType |
static interface |
Scheduler.MapSerializableRunnable |
static interface |
Scheduler.Synchronizer |
Modifier and Type | Method and Description |
---|---|
void |
acquireTransactionLocks() |
void |
cancelJob(java.lang.String jobId)
Make a good effort to cancel the job.
|
<T> java.util.concurrent.Future<T> |
execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
Same as execTransaction but executes in a different thread to guarantee
isolation from the main execution thread.
|
<T> T |
execTransaction(java.util.concurrent.Callable<T> transaction)
Execute a
Callable in a transactional context. |
<T> T |
execTransaction(java.util.concurrent.Callable<T> transaction,
int timeout)
Execute a
Callable in a transactional context. |
boolean |
isTransacted() |
void |
registerSynchronizer(Scheduler.Synchronizer synch)
Register a transaction synchronizer.
|
java.lang.String |
scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable runnable,
java.util.Date when)
Schedule a Runnable that will be executed on a dedicated thread pool.
|
java.lang.String |
schedulePersistedJob(Scheduler.JobDetails jobDetail,
java.util.Date when)
Schedule a persisted job.
|
java.lang.String |
scheduleVolatileJob(boolean transacted,
Scheduler.JobDetails jobDetail)
Schedule a volatile job for right now
|
java.lang.String |
scheduleVolatileJob(boolean transacted,
Scheduler.JobDetails jobDetail,
java.util.Date when)
Schedule a volatile (non-persisted) job.
|
void |
setJobProcessor(Scheduler.JobProcessor processor) |
void |
setPolledRunnableProcesser(Scheduler.JobProcessor polledRunnableProcessor) |
void |
setRollbackOnly() |
void |
shutdown() |
void |
start() |
void |
stop() |
void setJobProcessor(Scheduler.JobProcessor processor) throws ContextException
ContextException
void setPolledRunnableProcesser(Scheduler.JobProcessor polledRunnableProcessor)
java.lang.String schedulePersistedJob(Scheduler.JobDetails jobDetail, java.util.Date when) throws ContextException
jobDetail
- information about the jobwhen
- when the job should run (null
means now)ContextException
java.lang.String scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable runnable, java.util.Date when) throws ContextException
runnable
- when
- ContextException
java.lang.String scheduleVolatileJob(boolean transacted, Scheduler.JobDetails jobDetail, java.util.Date when) throws ContextException
transacted
- should the job be executed in a transaction?jobDetail
- information about the jobwhen
- does the job should be executed?ContextException
java.lang.String scheduleVolatileJob(boolean transacted, Scheduler.JobDetails jobDetail) throws ContextException
ContextException
#scheduleVolatileJob(boolean, java.util.Map, java.util.Date)
void cancelJob(java.lang.String jobId) throws ContextException
jobId
- job identifier of the jobContextException
<T> T execTransaction(java.util.concurrent.Callable<T> transaction) throws java.lang.Exception, ContextException
Callable
in a transactional context. If the callable
throws an exception, then the transaction will be rolled back, otherwise
the transaction will commit.T
- return typetransaction
- transaction to executejava.lang.Exception
ContextException
<T> T execTransaction(java.util.concurrent.Callable<T> transaction, int timeout) throws java.lang.Exception, ContextException
Callable
in a transactional context. If the callable
throws an exception, then the transaction will be rolled back, otherwise
the transaction will commit. Also, modify the value of the timeout value
that is associated with the transactions started by the current thread.T
- return typetransaction
- transaction to executetimeout,
- The value of the timeout in seconds. If the value is zero, the transaction service uses the default value.java.lang.Exception
ContextException
void setRollbackOnly() throws java.lang.Exception
java.lang.Exception
<T> java.util.concurrent.Future<T> execIsolatedTransaction(java.util.concurrent.Callable<T> transaction) throws java.lang.Exception, ContextException
transaction
- java.lang.Exception
ContextException
boolean isTransacted()
void registerSynchronizer(Scheduler.Synchronizer synch) throws ContextException
synch
- synchronizerContextException
void start()
void stop()
void shutdown()
void acquireTransactionLocks()