org.apache.ode.bpel.engine.replayer

Class ReplayerScheduler

java.lang.Object

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

All Implemented Interfaces:

Scheduler

public class ReplayerScheduler
extends java.lang.Object
implements Scheduler

Manages events invocation in sorted order during replaying.

Author:

Rafal Rusin

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.Scheduler

Scheduler.JobDetails, Scheduler.JobInfo, Scheduler.JobProcessor, Scheduler.JobProcessorException, Scheduler.JobType, Scheduler.MapSerializableRunnable, Scheduler.Synchronizer

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.ThreadLocal<org.apache.ode.bpel.engine.replayer.ReplayerScheduler.TaskElement>	currentTaskElement
Replayer	replayer

Constructor Summary

Constructors

Constructor and Description
ReplayerScheduler()

Method Summary

Modifier and Type	Method and Description
void	acquireTransactionLocks()
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(Scheduler.Synchronizer synch)
java.lang.String	scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable runnable, java.util.Date when)
java.lang.String	schedulePersistedJob(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, Scheduler.JobDetails jobDetail)
java.lang.String	scheduleVolatileJob(boolean transacted, Scheduler.JobDetails jobDetail, java.util.Date when)
void	setJobProcessor(Scheduler.JobProcessor processor)
void	setPolledRunnableProcesser(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 ContextException

Specified by:

cancelJob in interface Scheduler

Throws:

ContextException

execTransaction

public <T> T execTransaction(java.util.concurrent.Callable<T> transaction)
                      throws java.lang.Exception,
                             ContextException

Specified by:

execTransaction in interface Scheduler

Throws:

java.lang.Exception

ContextException

execTransaction

public <T> T execTransaction(java.util.concurrent.Callable<T> transaction,
                             int timeout)
                      throws java.lang.Exception,
                             ContextException

Specified by:

execTransaction in interface Scheduler

Throws:

java.lang.Exception

ContextException

isTransacted

public boolean isTransacted()

Specified by:

isTransacted in interface Scheduler

registerSynchronizer

public void registerSynchronizer(Scheduler.Synchronizer synch)
                          throws ContextException

Specified by:

registerSynchronizer in interface Scheduler

Throws:

ContextException

setJobProcessor

public void setJobProcessor(Scheduler.JobProcessor processor)
                     throws ContextException

Specified by:

setJobProcessor in interface Scheduler

Throws:

ContextException

setRollbackOnly

public void setRollbackOnly()
                     throws java.lang.Exception

Specified by:

setRollbackOnly in interface Scheduler

Throws:

java.lang.Exception

shutdown

public void shutdown()

Specified by:

shutdown in interface Scheduler

startReplaying

public void startReplaying(Replayer replayer)
                    throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()

Specified by:

stop in interface Scheduler

start

public void start()

Specified by:

start in interface Scheduler

execIsolatedTransaction

public <T> java.util.concurrent.Future<T> execIsolatedTransaction(java.util.concurrent.Callable<T> transaction)
                                                           throws java.lang.Exception,
                                                                  ContextException

Specified by:

execIsolatedTransaction in interface Scheduler

Throws:

java.lang.Exception

ContextException

scheduleMapSerializableRunnable

public java.lang.String scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable runnable,
                                                        java.util.Date when)
                                                 throws ContextException

Specified by:

scheduleMapSerializableRunnable in interface Scheduler

Throws:

ContextException

schedulePersistedJob

public java.lang.String schedulePersistedJob(Scheduler.JobDetails jobDetail,
                                             java.util.Date when1)
                                      throws ContextException

Specified by:

schedulePersistedJob in interface Scheduler

Throws:

ContextException

setPolledRunnableProcesser

public void setPolledRunnableProcesser(Scheduler.JobProcessor polledRunnableProcessor)

Specified by:

setPolledRunnableProcesser in interface Scheduler

scheduleVolatileJob

public java.lang.String scheduleVolatileJob(boolean transacted,
                                            Scheduler.JobDetails jobDetail,
                                            java.util.Date when)
                                     throws ContextException

Specified by:

scheduleVolatileJob in interface Scheduler

Throws:

ContextException

scheduleVolatileJob

public java.lang.String scheduleVolatileJob(boolean transacted,
                                            Scheduler.JobDetails jobDetail)
                                     throws ContextException

Specified by:

scheduleVolatileJob in interface Scheduler

Throws:

ContextException

acquireTransactionLocks

public void acquireTransactionLocks()

Specified by:

acquireTransactionLocks in interface Scheduler