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, update
public ProcessInstanceDaoImpl(SessionManager sm, HProcessInstance instance)
public java.util.Date getCreateTime()
ProcessInstanceDAO
getCreateTime
in interface ProcessInstanceDAO
ProcessInstanceDAO.getCreateTime()
public void setFault(FaultDAO fault)
ProcessInstanceDAO
null
if no fault occurred or if all faults are caught and
processed.setFault
in interface ProcessInstanceDAO
fault
- 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 ProcessInstanceDAO
ProcessInstanceDAO.setFault(javax.xml.namespace.QName, String, int, int, org.w3c.dom.Element)
public FaultDAO getFault()
ProcessInstanceDAO
null
if no fault occurred or if all faults are caught and
processed.getFault
in interface ProcessInstanceDAO
ProcessInstanceDAO.getFault()
public byte[] getExecutionState()
ProcessInstanceDAO
getExecutionState
in interface ProcessInstanceDAO
ProcessInstanceDAO.getExecutionState()
public void setExecutionState(byte[] bytes)
ProcessInstanceDAO
setExecutionState
in interface ProcessInstanceDAO
bytes
- execuction stateProcessInstanceDAO.setExecutionState(byte[])
public ProcessDAO getProcess()
ProcessInstanceDAO
getProcess
in interface ProcessInstanceDAO
ProcessInstanceDAO.getProcess()
public ScopeDAO getRootScope()
ProcessInstanceDAO
getRootScope
in interface ProcessInstanceDAO
ProcessInstanceDAO.getRootScope()
public void setState(short state)
ProcessInstanceDAO
STATE_XXX
constants defined in ProcessState.
This should automatically populate the previous state.setState
in interface ProcessInstanceDAO
state
- new state of the process instanceProcessInstanceDAO.setState(short)
public short getState()
ProcessInstanceDAO
STATE_XXX
constants defined in ProcessState.getState
in interface ProcessInstanceDAO
ProcessInstanceDAO.getState()
public short getPreviousState()
ProcessInstanceDAO
getPreviousState
in interface ProcessInstanceDAO
ProcessInstanceDAO.getPreviousState()
public ScopeDAO createScope(ScopeDAO parentScope, java.lang.String name, int scopeModelId)
ProcessInstanceDAO
createScope
in interface ProcessInstanceDAO
parentScope
- parent scope of the new scope, or null if this is the
root scope.name
- scope namepublic java.lang.Long getInstanceId()
ProcessInstanceDAO
getInstanceId
in interface ProcessInstanceDAO
ProcessInstanceDAO.getInstanceId()
public ScopeDAO getScope(java.lang.Long scopeInstanceId)
ProcessInstanceDAO
getScope
in interface ProcessInstanceDAO
public java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
ProcessInstanceDAO
getScopes
in interface ProcessInstanceDAO
ProcessInstanceDAO.getScopes(java.lang.String)
public java.util.Collection<ScopeDAO> getScopes()
ProcessInstanceDAO
getScopes
in interface ProcessInstanceDAO
public CorrelatorDAO getInstantiatingCorrelator()
ProcessInstanceDAO
getInstantiatingCorrelator
in interface ProcessInstanceDAO
ProcessInstanceDAO.getInstantiatingCorrelator()
public java.util.Date getLastActiveTime()
ProcessInstanceDAO
getLastActiveTime
in interface ProcessInstanceDAO
ProcessInstanceDAO.getLastActiveTime()
public void setLastActiveTime(java.util.Date dt)
ProcessInstanceDAO
setLastActiveTime
in interface ProcessInstanceDAO
dt
- tiem of activityProcessInstanceDAO.setLastActiveTime(java.util.Date)
public java.util.Set<CorrelationSetDAO> getCorrelationSets()
ProcessInstanceDAO
getCorrelationSets
in interface ProcessInstanceDAO
Set
of CorrelationSetDAO
objectspublic CorrelationSetDAO getCorrelationSet(java.lang.String name)
ProcessInstanceDAO
getCorrelationSet
in interface ProcessInstanceDAO
CorrelationSetDAO
objectpublic XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
getVariables
in interface ProcessInstanceDAO
ProcessInstanceDAO.getVariables(java.lang.String, int)
public void finishCompletion()
ProcessInstanceDAO
finishCompletion
in interface ProcessInstanceDAO
ProcessInstanceDAO.finishCompletion()
public void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
ProcessInstanceDAO
delete
in interface ProcessInstanceDAO
public void delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories, boolean deleteMyRoleMex)
ProcessInstanceDAO
delete
in interface ProcessInstanceDAO
cleanupCategories
- the categories of entities to deletedeleteMyRoleMex
- will clean up the my role mex if set to truepublic void insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAO
insertBpelEvent
in interface ProcessInstanceDAO
event
- BPEL eventpublic ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAO
getEventsFirstLastCount
in interface ProcessInstanceDAO
public java.util.Collection<MessageExchangeDAO> getMessageExchanges()
public long genMonotonic()
ProcessInstanceDAO
genMonotonic
in interface ProcessInstanceDAO
protected void clearSelectors()
public int getActivityFailureCount()
ProcessInstanceDAO
getActivityFailureCount
in interface ProcessInstanceDAO
public java.util.Date getActivityFailureDateTime()
ProcessInstanceDAO
getActivityFailureDateTime
in interface ProcessInstanceDAO
public java.util.Collection<ActivityRecoveryDAO> getActivityRecoveries()
ProcessInstanceDAO
getActivityRecoveries
in interface ProcessInstanceDAO
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)
ProcessInstanceDAO
createActivityRecovery
in interface ProcessInstanceDAO
public void deleteActivityRecovery(java.lang.String channel)
deleteActivityRecovery
in interface ProcessInstanceDAO
public BpelDAOConnection getConnection()
getConnection
in interface ProcessInstanceDAO
public java.util.Collection<java.lang.String> getMessageExchangeIds()
getMessageExchangeIds
in interface ProcessInstanceDAO