public class ProcessInstanceDaoImpl extends HibernateDao implements ProcessInstanceDAO
ProcessInstanceDAO implementation.ProcessInstanceDAO.EventsFirstLastCountTuple_hobj, _sm| Constructor and Description |
|---|
ProcessInstanceDaoImpl(SessionManager sm,
HProcessInstance instance) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
clearSelectors() |
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() |
java.util.Collection<MessageExchangeDAO> |
getMessageExchanges() |
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)
TODO this is never used, except by test cases - should be removed
|
void |
insertBpelEvent(ProcessInstanceEvent event)
Insert a BPEL event to the database (associating with this process).
|
void |
setExecutionState(byte[] bytes)
Set the (opaque) instance execution state.
|
void |
setFault(FaultDAO fault)
The un-caught fault associated with the process.
|
void |
setFault(javax.xml.namespace.QName name,
java.lang.String explanation,
int lineNo,
int activityId,
org.w3c.dom.Element faultData) |
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. |
deleteByColumn, deleteByIds, equals, getDHandle, getHibernateObj, getId, getSession, hashCode, updatepublic ProcessInstanceDaoImpl(SessionManager sm, HProcessInstance instance)
public java.util.Date getCreateTime()
ProcessInstanceDAOgetCreateTime in interface ProcessInstanceDAOProcessInstanceDAO.getCreateTime()public 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 name,
java.lang.String explanation,
int lineNo,
int activityId,
org.w3c.dom.Element faultData)
setFault in interface ProcessInstanceDAOProcessInstanceDAO.setFault(javax.xml.namespace.QName, String, int, int, org.w3c.dom.Element)public FaultDAO getFault()
ProcessInstanceDAOnull if no fault occurred or if all faults are caught and
processed.getFault in interface ProcessInstanceDAOProcessInstanceDAO.getFault()public byte[] getExecutionState()
ProcessInstanceDAOgetExecutionState in interface ProcessInstanceDAOProcessInstanceDAO.getExecutionState()public void setExecutionState(byte[] bytes)
ProcessInstanceDAOsetExecutionState in interface ProcessInstanceDAObytes - execuction stateProcessInstanceDAO.setExecutionState(byte[])public ProcessDAO getProcess()
ProcessInstanceDAOgetProcess in interface ProcessInstanceDAOProcessInstanceDAO.getProcess()public ScopeDAO getRootScope()
ProcessInstanceDAOgetRootScope in interface ProcessInstanceDAOProcessInstanceDAO.getRootScope()public 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 instanceProcessInstanceDAO.setState(short)public short getState()
ProcessInstanceDAOSTATE_XXX
constants defined in ProcessState.getState in interface ProcessInstanceDAOProcessInstanceDAO.getState()public short getPreviousState()
ProcessInstanceDAOgetPreviousState in interface ProcessInstanceDAOProcessInstanceDAO.getPreviousState()public 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.lang.Long getInstanceId()
ProcessInstanceDAOgetInstanceId in interface ProcessInstanceDAOProcessInstanceDAO.getInstanceId()public ScopeDAO getScope(java.lang.Long scopeInstanceId)
ProcessInstanceDAOgetScope in interface ProcessInstanceDAOpublic java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOProcessInstanceDAO.getScopes(java.lang.String)public java.util.Collection<ScopeDAO> getScopes()
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOpublic CorrelatorDAO getInstantiatingCorrelator()
ProcessInstanceDAOgetInstantiatingCorrelator in interface ProcessInstanceDAOProcessInstanceDAO.getInstantiatingCorrelator()public java.util.Date getLastActiveTime()
ProcessInstanceDAOgetLastActiveTime in interface ProcessInstanceDAOProcessInstanceDAO.getLastActiveTime()public void setLastActiveTime(java.util.Date dt)
ProcessInstanceDAOsetLastActiveTime in interface ProcessInstanceDAOdt - tiem of activityProcessInstanceDAO.setLastActiveTime(java.util.Date)public java.util.Set<CorrelationSetDAO> getCorrelationSets()
ProcessInstanceDAOgetCorrelationSets in interface ProcessInstanceDAOSet of CorrelationSetDAO objectspublic CorrelationSetDAO getCorrelationSet(java.lang.String name)
ProcessInstanceDAOgetCorrelationSet in interface ProcessInstanceDAOCorrelationSetDAO objectpublic XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
getVariables in interface ProcessInstanceDAOProcessInstanceDAO.getVariables(java.lang.String, int)public void finishCompletion()
ProcessInstanceDAOfinishCompletion in interface ProcessInstanceDAOProcessInstanceDAO.finishCompletion()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 insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAOinsertBpelEvent in interface ProcessInstanceDAOevent - BPEL eventpublic ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAOgetEventsFirstLastCount in interface ProcessInstanceDAOpublic java.util.Collection<MessageExchangeDAO> getMessageExchanges()
public long genMonotonic()
ProcessInstanceDAOgenMonotonic in interface ProcessInstanceDAOprotected void clearSelectors()
public int getActivityFailureCount()
ProcessInstanceDAOgetActivityFailureCount in interface ProcessInstanceDAOpublic java.util.Date getActivityFailureDateTime()
ProcessInstanceDAOgetActivityFailureDateTime in interface ProcessInstanceDAOpublic java.util.Collection<ActivityRecoveryDAO> getActivityRecoveries()
ProcessInstanceDAOgetActivityRecoveries in interface ProcessInstanceDAOpublic 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 void deleteActivityRecovery(java.lang.String channel)
deleteActivityRecovery in interface ProcessInstanceDAOpublic BpelDAOConnection getConnection()
getConnection in interface ProcessInstanceDAOpublic java.util.Collection<java.lang.String> getMessageExchangeIds()
getMessageExchangeIds in interface ProcessInstanceDAO