org.apache.ode.bpel.engine.replayer
Class Replayer
java.lang.Object
org.apache.ode.bpel.engine.replayer.Replayer
public class Replayer
- extends java.lang.Object
Main class used for replaying. It's invoked from InstanceManagement API.
Receives request and sets up replaying contexts for each instance to replay.
|
Method Summary |
ReplayerContext |
findReplayedInstance(long iid)
|
org.apache.ode.bpel.pmapi.GetCommunicationResponse |
getCommunication(org.apache.ode.bpel.pmapi.GetCommunication request,
org.apache.ode.bpel.dao.BpelDAOConnection conn)
|
void |
handleJobDetails(org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail,
java.util.Date when)
|
java.util.List<java.lang.Long> |
replayInstances(org.apache.ode.bpel.pmapi.Replay request,
org.apache.ode.bpel.iapi.BpelEngine engine,
org.apache.ode.bpel.dao.BpelDAOConnection conn)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
replayer
public static java.lang.ThreadLocal<Replayer> replayer
scheduler
public ReplayerScheduler scheduler
engine
public BpelEngineImpl engine
contexts
public java.util.List<ReplayerContext> contexts
conn
public org.apache.ode.bpel.dao.BpelDAOConnection conn
Replayer
public Replayer()
replayInstances
public java.util.List<java.lang.Long> replayInstances(org.apache.ode.bpel.pmapi.Replay request,
org.apache.ode.bpel.iapi.BpelEngine engine,
org.apache.ode.bpel.dao.BpelDAOConnection conn)
throws java.lang.Exception
- Throws:
java.lang.Exception
getCommunication
public org.apache.ode.bpel.pmapi.GetCommunicationResponse getCommunication(org.apache.ode.bpel.pmapi.GetCommunication request,
org.apache.ode.bpel.dao.BpelDAOConnection conn)
throws java.lang.Exception
- Throws:
java.lang.Exception
findReplayedInstance
public ReplayerContext findReplayedInstance(long iid)
handleJobDetails
public void handleJobDetails(org.apache.ode.bpel.iapi.Scheduler.JobDetails jobDetail,
java.util.Date when)