org.apache.ode.bpel.engine.replayer
Class ReplayerScheduler
java.lang.Object
org.apache.ode.bpel.engine.replayer.ReplayerScheduler
- All Implemented Interfaces:
- org.apache.ode.bpel.iapi.Scheduler
public class ReplayerScheduler
- extends java.lang.Object
- implements org.apache.ode.bpel.iapi.Scheduler
Manages events invocation in sorted order during replaying.
| Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.Scheduler |
org.apache.ode.bpel.iapi.Scheduler.JobDetails, org.apache.ode.bpel.iapi.Scheduler.JobInfo, org.apache.ode.bpel.iapi.Scheduler.JobProcessor, org.apache.ode.bpel.iapi.Scheduler.JobProcessorException, org.apache.ode.bpel.iapi.Scheduler.JobType, org.apache.ode.bpel.iapi.Scheduler.MapSerializableRunnable, org.apache.ode.bpel.iapi.Scheduler.Synchronizer |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
replayer
public Replayer replayer
currentTaskElement
public static java.lang.ThreadLocal<org.apache.ode.bpel.engine.replayer.ReplayerScheduler.TaskElement> currentTaskElement
ReplayerScheduler
public ReplayerScheduler()
scheduleReplayerJob
public void scheduleReplayerJob(java.util.concurrent.Callable action,
java.util.Date when,
ReplayerBpelRuntimeContextImpl runtimeContext)
cancelJob
public void cancelJob(java.lang.String jobId)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
cancelJob in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
execTransaction
public <T> T execTransaction(java.util.concurrent.Callable<T> transaction)
throws java.lang.Exception,
org.apache.ode.bpel.iapi.ContextException
- Specified by:
execTransaction in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
java.lang.Exception
org.apache.ode.bpel.iapi.ContextException
execTransaction
public <T> T execTransaction(java.util.concurrent.Callable<T> transaction,
int timeout)
throws java.lang.Exception,
org.apache.ode.bpel.iapi.ContextException
- Specified by:
execTransaction in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
java.lang.Exception
org.apache.ode.bpel.iapi.ContextException
isTransacted
public boolean isTransacted()
- Specified by:
isTransacted in interface org.apache.ode.bpel.iapi.Scheduler
registerSynchronizer
public void registerSynchronizer(org.apache.ode.bpel.iapi.Scheduler.Synchronizer synch)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
registerSynchronizer in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
setJobProcessor
public void setJobProcessor(org.apache.ode.bpel.iapi.Scheduler.JobProcessor processor)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
setJobProcessor in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
setRollbackOnly
public void setRollbackOnly()
throws java.lang.Exception
- Specified by:
setRollbackOnly in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
java.lang.Exception
shutdown
public void shutdown()
- Specified by:
shutdown in interface org.apache.ode.bpel.iapi.Scheduler
startReplaying
public void startReplaying(Replayer replayer)
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
- Specified by:
stop in interface org.apache.ode.bpel.iapi.Scheduler
start
public void start()
- Specified by:
start in interface org.apache.ode.bpel.iapi.Scheduler
execIsolatedTransaction
public <T> java.util.concurrent.Future<T> execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
throws java.lang.Exception,
org.apache.ode.bpel.iapi.ContextException
- Specified by:
execIsolatedTransaction in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
java.lang.Exception
org.apache.ode.bpel.iapi.ContextException
scheduleMapSerializableRunnable
public java.lang.String scheduleMapSerializableRunnable(org.apache.ode.bpel.iapi.Scheduler.MapSerializableRunnable runnable,
java.util.Date when)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
scheduleMapSerializableRunnable in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
schedulePersistedJob
public java.lang.String schedulePersistedJob(org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail,
java.util.Date when1)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
schedulePersistedJob in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
setPolledRunnableProcesser
public void setPolledRunnableProcesser(org.apache.ode.bpel.iapi.Scheduler.JobProcessor polledRunnableProcessor)
- Specified by:
setPolledRunnableProcesser in interface org.apache.ode.bpel.iapi.Scheduler
scheduleVolatileJob
public java.lang.String scheduleVolatileJob(boolean transacted,
org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail,
java.util.Date when)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
scheduleVolatileJob in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException
scheduleVolatileJob
public java.lang.String scheduleVolatileJob(boolean transacted,
org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail)
throws org.apache.ode.bpel.iapi.ContextException
- Specified by:
scheduleVolatileJob in interface org.apache.ode.bpel.iapi.Scheduler
- Throws:
org.apache.ode.bpel.iapi.ContextException