public interface ProcessInstanceDAO
Modifier and Type | Interface and Description |
---|---|
static class |
ProcessInstanceDAO.EventsFirstLastCountTuple
Transport object holding the date of the first and last instance event
along with the number events.
|
Modifier and Type | Method and Description |
---|---|
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.
|
void |
delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
Delete the process instance object from the database.
|
void |
delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories,
boolean deleteMyRoleMex)
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.
|
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).
|
java.util.Collection<java.lang.String> |
getMessageExchangeIds() |
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 |
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. |
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 namejava.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()
void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories, boolean deleteMyRoleMex)
cleanupCategories
- the categories of entities to deletedeleteMyRoleMex
- will clean up the my role mex if set to truevoid 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)
java.util.Collection<java.lang.String> getMessageExchangeIds()