@Entity public class ProcessInstanceDAOImpl extends OpenJPADAO implements ProcessInstanceDAO
ProcessInstanceDAO.EventsFirstLastCountTuple| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID |
static java.lang.String |
COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_IDS |
static java.lang.String |
COUNT_INSTANCE_IDS_BY_PROCESS |
static java.lang.String |
COUNT_INSTANCES_BY_PROCESSES_IDS_AND_STATES |
static java.lang.String |
DELETE_INSTANCES_BY_PROCESS |
static java.lang.String |
SELECT_FAULT_IDS_BY_PROCESS |
static java.lang.String |
SELECT_INSTANCE_IDS_BY_PROCESS |
| Constructor and Description |
|---|
ProcessInstanceDAOImpl() |
ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator,
ProcessDAOImpl process) |
| 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).
|
java.util.Collection<CorrelationSetDAO> |
selectCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances) |
void |
setActivityFailureCount(int activityFailureCount) |
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. |
batchUpdateByIds, getConn, getEM, getSingleResultpublic static final java.lang.String DELETE_INSTANCES_BY_PROCESS
public static final java.lang.String SELECT_INSTANCE_IDS_BY_PROCESS
public static final java.lang.String COUNT_INSTANCE_IDS_BY_PROCESS
public static final java.lang.String SELECT_FAULT_IDS_BY_PROCESS
public static final java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID
public static final java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_IDS
public static final java.lang.String COUNT_INSTANCES_BY_PROCESSES_IDS_AND_STATES
public ProcessInstanceDAOImpl()
public ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator, ProcessDAOImpl process)
public 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)
ProcessInstanceDAOcreateActivityRecovery in interface ProcessInstanceDAOpublic ScopeDAO createScope(ScopeDAO parentScope, java.lang.String name, int scopeModelId)
ProcessInstanceDAOcreateScope in interface ProcessInstanceDAOparentScope - parent scope of the new scope, or null if this is the
root scope.name - scope namepublic java.util.Collection<CorrelationSetDAO> selectCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances)
public void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
ProcessInstanceDAOdelete in interface ProcessInstanceDAOpublic void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories, boolean deleteMyRoleMex)
ProcessInstanceDAOdelete in interface ProcessInstanceDAOcleanupCategories - the categories of entities to deletedeleteMyRoleMex - will clean up the my role mex if set to truepublic void deleteActivityRecovery(java.lang.String channel)
ProcessInstanceDAOdeleteActivityRecovery in interface ProcessInstanceDAOpublic void finishCompletion()
ProcessInstanceDAOfinishCompletion in interface ProcessInstanceDAOpublic long genMonotonic()
ProcessInstanceDAOgenMonotonic in interface ProcessInstanceDAOpublic int getActivityFailureCount()
ProcessInstanceDAOgetActivityFailureCount in interface ProcessInstanceDAOpublic void setActivityFailureCount(int activityFailureCount)
public java.util.Date getActivityFailureDateTime()
ProcessInstanceDAOgetActivityFailureDateTime in interface ProcessInstanceDAOpublic java.util.Collection<ActivityRecoveryDAO> getActivityRecoveries()
ProcessInstanceDAOgetActivityRecoveries in interface ProcessInstanceDAOpublic CorrelationSetDAO getCorrelationSet(java.lang.String name)
ProcessInstanceDAOgetCorrelationSet in interface ProcessInstanceDAOCorrelationSetDAO objectpublic java.util.Set<CorrelationSetDAO> getCorrelationSets()
ProcessInstanceDAOgetCorrelationSets in interface ProcessInstanceDAOSet of CorrelationSetDAO objectspublic java.util.Date getCreateTime()
ProcessInstanceDAOgetCreateTime in interface ProcessInstanceDAOpublic ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAOgetEventsFirstLastCount in interface ProcessInstanceDAOpublic byte[] getExecutionState()
ProcessInstanceDAOgetExecutionState in interface ProcessInstanceDAOpublic FaultDAO getFault()
ProcessInstanceDAOnull if no fault occurred or if all faults are caught and
processed.getFault in interface ProcessInstanceDAOpublic java.lang.Long getInstanceId()
ProcessInstanceDAOgetInstanceId in interface ProcessInstanceDAOpublic CorrelatorDAO getInstantiatingCorrelator()
ProcessInstanceDAOgetInstantiatingCorrelator in interface ProcessInstanceDAOpublic java.util.Date getLastActiveTime()
ProcessInstanceDAOgetLastActiveTime in interface ProcessInstanceDAOpublic short getPreviousState()
ProcessInstanceDAOgetPreviousState in interface ProcessInstanceDAOpublic ProcessDAO getProcess()
ProcessInstanceDAOgetProcess in interface ProcessInstanceDAOpublic ScopeDAO getRootScope()
ProcessInstanceDAOgetRootScope in interface ProcessInstanceDAOpublic ScopeDAO getScope(java.lang.Long scopeInstanceId)
ProcessInstanceDAOgetScope in interface ProcessInstanceDAOpublic java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOpublic java.util.Collection<ScopeDAO> getScopes()
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOpublic short getState()
ProcessInstanceDAOSTATE_XXX
constants defined in ProcessState.getState in interface ProcessInstanceDAOpublic XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
ProcessInstanceDAOgetVariables in interface ProcessInstanceDAOpublic void insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAOinsertBpelEvent in interface ProcessInstanceDAOevent - BPEL eventpublic void setExecutionState(byte[] execState)
ProcessInstanceDAOsetExecutionState in interface ProcessInstanceDAOexecState - execuction statepublic void setFault(FaultDAO fault)
ProcessInstanceDAOnull if no fault occurred or if all faults are caught and
processed.setFault in interface ProcessInstanceDAOfault - the faultpublic void setFault(javax.xml.namespace.QName faultName,
java.lang.String explanation,
int faultLineNo,
int activityId,
org.w3c.dom.Element faultMessage)
setFault in interface ProcessInstanceDAOpublic void setLastActiveTime(java.util.Date dt)
ProcessInstanceDAOsetLastActiveTime in interface ProcessInstanceDAOdt - tiem of activitypublic void setState(short state)
ProcessInstanceDAOSTATE_XXX
constants defined in ProcessState.
This should automatically populate the previous state.setState in interface ProcessInstanceDAOstate - new state of the process instancepublic BpelDAOConnection getConnection()
getConnection in interface ProcessInstanceDAOpublic java.util.Collection<java.lang.String> getMessageExchangeIds()
getMessageExchangeIds in interface ProcessInstanceDAO