|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ProcessInstanceDAO
BPEL process instance data access object. This object serves as the root object for data related to a particular process instance; this state includes auditing events, scopes, pick/received waiters, and the serialized process instance image.
Nested Class Summary | |
---|---|
static class |
ProcessInstanceDAO.EventsFirstLastCountTuple
Transport object holding the date of the first and last instance event along with the number events. |
Method Summary | |
---|---|
void |
createActivityRecovery(java.lang.String channel,
long activityId,
java.lang.String reason,
java.util.Date dateTime,
org.w3c.dom.Element data,
java.lang.String[] actions,
int retries)
Create an activity recovery object for a given activity instance. |
ScopeDAO |
createScope(ScopeDAO parentScope,
java.lang.String name,
int scopeModelId)
Creates a new scope. |
boolean |
delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
Delete the process instance object from the database. |
void |
deleteActivityRecovery(java.lang.String channel)
Delete previously registered activity recovery. |
void |
finishCompletion()
A simple callback to allow the ProcessInstance to perform post-completion duties. |
long |
genMonotonic()
Get the next number from a monotonically increasing sequence. |
int |
getActivityFailureCount()
Get number of activities in the failure state. |
java.util.Date |
getActivityFailureDateTime()
Get date/time of last activity failure. |
java.util.Collection<ActivityRecoveryDAO> |
getActivityRecoveries()
Returns all activity recovery objects for this process instance. |
BpelDAOConnection |
getConnection()
|
CorrelationSetDAO |
getCorrelationSet(java.lang.String name)
Get a correlation set by its name from this process |
java.util.Set<CorrelationSetDAO> |
getCorrelationSets()
Get all the correlation sets for this process. |
java.util.Date |
getCreateTime()
Get the time when the process instance was created. |
ProcessInstanceDAO.EventsFirstLastCountTuple |
getEventsFirstLastCount()
Get a triple containing the first |
byte[] |
getExecutionState()
Get the (opaque) instance execution state. |
int |
getExecutionStateCounter()
|
FaultDAO |
getFault()
The un-caught fault associated with the process. |
java.lang.Long |
getInstanceId()
Get the instance identifier. |
CorrelatorDAO |
getInstantiatingCorrelator()
Return the correlator which results in the instantiation of the process instance. |
java.util.Date |
getLastActiveTime()
Get the time when the process instance was last active (re-hydrated). |
short |
getPreviousState()
Returns the next to last state. |
ProcessDAO |
getProcess()
Get the process. |
ScopeDAO |
getRootScope()
Get the root (global) scope for the process. |
ScopeDAO |
getScope(java.lang.Long scopeInstanceId)
Returns a scope using its instance id. |
java.util.Collection<ScopeDAO> |
getScopes()
Returns all the scopes belonging to this isntance. |
java.util.Collection<ScopeDAO> |
getScopes(java.lang.String scopeName)
Returns all the scopes with the associated name. |
short |
getState()
Get the state of the process instance; one of the STATE_XXX constants defined in ProcessState. |
XmlDataDAO[] |
getVariables(java.lang.String variableName,
int scopeModelId)
Returns all variable instances matching the variable name for a specified scope. |
void |
insertBpelEvent(ProcessInstanceEvent event)
Insert a BPEL event to the database (associating with this process). |
void |
setExecutionState(byte[] execState)
Set the (opaque) instance execution state. |
void |
setExecutionStateCounter(int stateCounter)
|
void |
setFault(FaultDAO fault)
The un-caught fault associated with the process. |
void |
setFault(javax.xml.namespace.QName faultName,
java.lang.String explanation,
int faultLineNo,
int activityId,
org.w3c.dom.Element faultMessage)
|
void |
setLastActiveTime(java.util.Date dt)
Set last activity time for the process instance |
void |
setState(short state)
Set the state of the process instance; one of the STATE_XXX constants defined in ProcessState. |
Method Detail |
---|
java.util.Date getCreateTime()
java.util.Date getLastActiveTime()
void setLastActiveTime(java.util.Date dt)
dt
- tiem of activityvoid setFault(FaultDAO fault)
null
if no fault occurred or if all faults are
caught and processed.
fault
- the faultvoid setFault(javax.xml.namespace.QName faultName, java.lang.String explanation, int faultLineNo, int activityId, org.w3c.dom.Element faultMessage)
FaultDAO getFault()
null
if no fault occurred or if all faults are
caught and processed.
byte[] getExecutionState()
void setExecutionState(byte[] execState)
execState
- execuction stateProcessDAO getProcess()
ScopeDAO getRootScope()
void setState(short state)
STATE_XXX
constants defined in ProcessState.
This should automatically populate the previous state.
state
- new state of the process instanceshort getState()
STATE_XXX
constants defined in ProcessState.
short getPreviousState()
ScopeDAO createScope(ScopeDAO parentScope, java.lang.String name, int scopeModelId)
parentScope
- parent scope of the new scope, or null if this is the root scope.name
- scope name
java.lang.Long getInstanceId()
ScopeDAO getScope(java.lang.Long scopeInstanceId)
scopeInstanceId
-
java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
scopeName
-
java.util.Collection<ScopeDAO> getScopes()
scopeName
-
CorrelatorDAO getInstantiatingCorrelator()
XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
java.util.Set<CorrelationSetDAO> getCorrelationSets()
Set
of CorrelationSetDAO
objectsCorrelationSetDAO getCorrelationSet(java.lang.String name)
name
-
CorrelationSetDAO
objectvoid finishCompletion()
boolean delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
void insertBpelEvent(ProcessInstanceEvent event)
event
- BPEL eventProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
long genMonotonic()
BpelDAOConnection getConnection()
int getActivityFailureCount()
java.util.Date getActivityFailureDateTime()
java.util.Collection<ActivityRecoveryDAO> getActivityRecoveries()
void createActivityRecovery(java.lang.String channel, long activityId, java.lang.String reason, java.util.Date dateTime, org.w3c.dom.Element data, java.lang.String[] actions, int retries)
void deleteActivityRecovery(java.lang.String channel)
int getExecutionStateCounter()
void setExecutionStateCounter(int stateCounter)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |