|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Scheduler
The BPEL scheduler.
Nested Class Summary | |
---|---|
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
|
Method Summary | ||
---|---|---|
void |
cancelJob(java.lang.String jobId)
Make a good effort to cancel the job. |
|
|
execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
Same as execTransaction but executes in a different thread to guarantee isolation from the main execution thread. |
|
|
execTransaction(java.util.concurrent.Callable<T> transaction)
Execute a Callable in a transactional context. |
|
|
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()
|
Method Detail |
---|
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 job
ContextException
<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 execute
java.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
- synchronizer
ContextException
void start()
void stop()
void shutdown()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |