org.apache.ode.bpel.engine.replayer
Class ReplayerScheduler

java.lang.Object
  extended by 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 Class Summary
 
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
 
Field Summary
static java.lang.ThreadLocal<org.apache.ode.bpel.engine.replayer.ReplayerScheduler.TaskElement> currentTaskElement
           
 Replayer replayer
           
 
Constructor Summary
ReplayerScheduler()
           
 
Method Summary
 void cancelJob(java.lang.String jobId)
           
<T> java.util.concurrent.Future<T>
execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
           
<T> T
execTransaction(java.util.concurrent.Callable<T> transaction)
           
<T> T
execTransaction(java.util.concurrent.Callable<T> transaction, int timeout)
           
 boolean isTransacted()
           
 void registerSynchronizer(org.apache.ode.bpel.iapi.Scheduler.Synchronizer synch)
           
 java.lang.String scheduleMapSerializableRunnable(org.apache.ode.bpel.iapi.Scheduler.MapSerializableRunnable runnable, java.util.Date when)
           
 java.lang.String schedulePersistedJob(org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail, java.util.Date when1)
           
 void scheduleReplayerJob(java.util.concurrent.Callable action, java.util.Date when, ReplayerBpelRuntimeContextImpl runtimeContext)
           
 java.lang.String scheduleVolatileJob(boolean transacted, org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail)
           
 java.lang.String scheduleVolatileJob(boolean transacted, org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail, java.util.Date when)
           
 void setJobProcessor(org.apache.ode.bpel.iapi.Scheduler.JobProcessor processor)
           
 void setPolledRunnableProcesser(org.apache.ode.bpel.iapi.Scheduler.JobProcessor polledRunnableProcessor)
           
 void setRollbackOnly()
           
 void shutdown()
           
 void start()
           
 void startReplaying(Replayer replayer)
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

replayer

public Replayer replayer

currentTaskElement

public static java.lang.ThreadLocal<org.apache.ode.bpel.engine.replayer.ReplayerScheduler.TaskElement> currentTaskElement
Constructor Detail

ReplayerScheduler

public ReplayerScheduler()
Method Detail

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