org.apache.ode.il
Class MockScheduler

java.lang.Object
  extended by org.apache.ode.il.MockScheduler
All Implemented Interfaces:
org.apache.ode.bpel.iapi.Scheduler

public class MockScheduler
extends java.lang.Object
implements org.apache.ode.bpel.iapi.Scheduler


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
 
Constructor Summary
MockScheduler()
           
MockScheduler(javax.transaction.TransactionManager txm)
           
 
Method Summary
 boolean amICoordinator()
           
 void beginTransaction()
           
 void cancelJob(java.lang.String arg0)
           
 void commitTransaction()
           
<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)
           
 void rollbackTransaction()
           
 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 detail, java.util.Date date)
           
 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 detail, java.util.Date date)
           
 void setExecutorSvc(java.util.concurrent.ExecutorService executorSvc)
           
 void setJobProcessor(org.apache.ode.bpel.iapi.Scheduler.JobProcessor processor)
           
 void setPolledRunnableProcesser(org.apache.ode.bpel.iapi.Scheduler.JobProcessor delegatedRunnableProcessor)
           
 void setRollbackOnly()
           
 void shutdown()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MockScheduler

public MockScheduler()

MockScheduler

public MockScheduler(javax.transaction.TransactionManager txm)
Method Detail

schedulePersistedJob

public java.lang.String schedulePersistedJob(org.apache.ode.bpel.iapi.Scheduler.JobDetails detail,
                                             java.util.Date date)
                                      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

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

scheduleVolatileJob

public java.lang.String scheduleVolatileJob(boolean transacted,
                                            org.apache.ode.bpel.iapi.Scheduler.JobDetails detail,
                                            java.util.Date date)
                                     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

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

cancelJob

public void cancelJob(java.lang.String arg0)
               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

setRollbackOnly

public void setRollbackOnly()
                     throws java.lang.Exception
Specified by:
setRollbackOnly in interface org.apache.ode.bpel.iapi.Scheduler
Throws:
java.lang.Exception

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

isTransacted

public boolean isTransacted()
Specified by:
isTransacted in interface org.apache.ode.bpel.iapi.Scheduler

start

public void start()
Specified by:
start in interface org.apache.ode.bpel.iapi.Scheduler

stop

public void stop()
Specified by:
stop in interface org.apache.ode.bpel.iapi.Scheduler

shutdown

public void shutdown()
Specified by:
shutdown 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

beginTransaction

public void beginTransaction()

commitTransaction

public void commitTransaction()

rollbackTransaction

public void rollbackTransaction()

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

setExecutorSvc

public void setExecutorSvc(java.util.concurrent.ExecutorService executorSvc)

setPolledRunnableProcesser

public void setPolledRunnableProcesser(org.apache.ode.bpel.iapi.Scheduler.JobProcessor delegatedRunnableProcessor)
Specified by:
setPolledRunnableProcesser in interface org.apache.ode.bpel.iapi.Scheduler

amICoordinator

public boolean amICoordinator()