Scheduler.JobDetails, Scheduler.JobInfo, Scheduler.JobProcessor, Scheduler.JobProcessorException, Scheduler.JobType, Scheduler.MapSerializableRunnable, Scheduler.Synchronizer| Constructor and Description |
|---|
MockScheduler() |
MockScheduler(javax.transaction.TransactionManager txm) |
| Modifier and Type | Method and Description |
|---|---|
void |
acquireTransactionLocks() |
boolean |
amICoordinator() |
void |
beginTransaction() |
void |
cancelJob(java.lang.String arg0)
Make a good effort to cancel the job.
|
void |
commitTransaction() |
<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.
|
void |
rollbackTransaction() |
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 detail,
java.util.Date date)
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 detail,
java.util.Date date)
Schedule a volatile (non-persisted) job.
|
void |
setExecutorSvc(java.util.concurrent.ExecutorService executorSvc) |
void |
setJobProcessor(Scheduler.JobProcessor processor) |
void |
setPolledRunnableProcesser(Scheduler.JobProcessor delegatedRunnableProcessor) |
void |
setRollbackOnly() |
void |
shutdown() |
void |
start() |
void |
stop() |
public MockScheduler()
public MockScheduler(javax.transaction.TransactionManager txm)
public java.lang.String schedulePersistedJob(Scheduler.JobDetails detail, java.util.Date date) throws ContextException
SchedulerschedulePersistedJob in interface Schedulerdetail - information about the jobdate - when the job should run (null means now)ContextExceptionpublic java.lang.String scheduleVolatileJob(boolean transacted,
Scheduler.JobDetails jobDetail)
throws ContextException
SchedulerscheduleVolatileJob in interface SchedulerContextException#scheduleVolatileJob(boolean, java.util.Map, java.util.Date)public java.lang.String scheduleVolatileJob(boolean transacted,
Scheduler.JobDetails detail,
java.util.Date date)
throws ContextException
SchedulerscheduleVolatileJob in interface Schedulertransacted - should the job be executed in a transaction?detail - information about the jobdate - does the job should be executed?ContextExceptionpublic java.lang.String scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable runnable, java.util.Date when) throws ContextException
SchedulerscheduleMapSerializableRunnable in interface SchedulerContextExceptionpublic void cancelJob(java.lang.String arg0)
throws ContextException
SchedulercancelJob in interface Schedulerarg0 - job identifier of the jobContextExceptionpublic <T> T execTransaction(java.util.concurrent.Callable<T> transaction)
throws java.lang.Exception,
ContextException
SchedulerCallable in a transactional context. If the callable
throws an exception, then the transaction will be rolled back, otherwise
the transaction will commit.execTransaction in interface SchedulerT - return typetransaction - transaction to executejava.lang.ExceptionContextExceptionpublic <T> T execTransaction(java.util.concurrent.Callable<T> transaction,
int timeout)
throws java.lang.Exception,
ContextException
SchedulerCallable 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.execTransaction in interface SchedulerT - return typetransaction - transaction to executejava.lang.ExceptionContextExceptionpublic void setRollbackOnly()
throws java.lang.Exception
setRollbackOnly in interface Schedulerjava.lang.Exceptionpublic <T> java.util.concurrent.Future<T> execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
throws java.lang.Exception,
ContextException
SchedulerexecIsolatedTransaction in interface Schedulerjava.lang.ExceptionContextExceptionpublic boolean isTransacted()
isTransacted in interface Schedulerpublic void acquireTransactionLocks()
acquireTransactionLocks in interface Schedulerpublic void registerSynchronizer(Scheduler.Synchronizer synch) throws ContextException
SchedulerregisterSynchronizer in interface Schedulersynch - synchronizerContextExceptionpublic void beginTransaction()
public void commitTransaction()
public void rollbackTransaction()
public void setJobProcessor(Scheduler.JobProcessor processor) throws ContextException
setJobProcessor in interface SchedulerContextExceptionpublic void setExecutorSvc(java.util.concurrent.ExecutorService executorSvc)
public void setPolledRunnableProcesser(Scheduler.JobProcessor delegatedRunnableProcessor)
setPolledRunnableProcesser in interface Schedulerpublic boolean amICoordinator()