public class ProcessInstanceDaoImpl extends java.lang.Object implements ProcessInstanceDAO
ProcessInstanceDAO
interface.ProcessInstanceDAO.EventsFirstLastCountTuple
Modifier and Type | Method and Description |
---|---|
void |
addMessageExchange(java.lang.String identifier,
byte[] data) |
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 scopeType,
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() |
int |
getEventCount() |
java.util.List<ProcessInstanceEvent> |
getEvents(int idx,
int count) |
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).
|
byte[] |
getMessageExchange(java.lang.String identifier) |
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.
|
java.lang.Object |
getSoup() |
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[] 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 |
setSoup(java.lang.Object soup) |
void |
setState(short state)
Set the state of the process instance; one of the
STATE_XXX
constants defined in ProcessState. |
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCreateTime
public XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
ProcessInstanceDAO
getVariables
in interface ProcessInstanceDAO
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 void setFault(javax.xml.namespace.QName name, java.lang.String explanation, int lineNo, int activityId, org.w3c.dom.Element faultData)
setFault
in interface ProcessInstanceDAO
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 FaultDAO getFault()
ProcessInstanceDAO
null
if no fault occurred or if all faults are caught and
processed.getFault
in interface ProcessInstanceDAO
public byte[] getExecutionState()
ProcessInstanceDAO
getExecutionState
in interface ProcessInstanceDAO
ProcessInstanceDAO.getExecutionState()
public void setExecutionState(byte[] bytes)
ProcessInstanceDAO
setExecutionState
in interface ProcessInstanceDAO
bytes
- execuction statepublic java.lang.Object getSoup()
public void setSoup(java.lang.Object soup)
public byte[] getMessageExchange(java.lang.String identifier)
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 void addMessageExchange(java.lang.String identifier, byte[] data)
public ScopeDAO createScope(ScopeDAO parentScope, java.lang.String scopeType, int scopeModelId)
ProcessInstanceDAO
createScope
in interface ProcessInstanceDAO
parentScope
- parent scope of the new scope, or null if this is the
root scope.scopeType
- scope namepublic java.lang.Long getInstanceId()
ProcessInstanceDAO
getInstanceId
in interface ProcessInstanceDAO
public ScopeDAO getScope(java.lang.Long scopeInstanceId)
ProcessInstanceDAO
getScope
in interface ProcessInstanceDAO
ProcessInstanceDAO.getScope(java.lang.Long)
public java.util.List<ProcessInstanceEvent> getEvents(int idx, int count)
public void insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAO
insertBpelEvent
in interface ProcessInstanceDAO
event
- BPEL eventProcessInstanceDAO.insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent)
public int getEventCount()
public CorrelatorDAO getInstantiatingCorrelator()
ProcessInstanceDAO
getInstantiatingCorrelator
in interface ProcessInstanceDAO
ProcessInstanceDAO.getInstantiatingCorrelator()
public java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
ProcessInstanceDAO
getScopes
in interface ProcessInstanceDAO
ProcessInstanceDAO.getScopes(java.lang.String)
public short getPreviousState()
ProcessInstanceDAO
getPreviousState
in interface ProcessInstanceDAO
ProcessInstanceDAO.getPreviousState()
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 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 java.util.Collection<ScopeDAO> getScopes()
ProcessInstanceDAO
getScopes
in interface ProcessInstanceDAO
public ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAO
getEventsFirstLastCount
in interface ProcessInstanceDAO
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)
ProcessInstanceDAO
deleteActivityRecovery
in interface ProcessInstanceDAO
public long genMonotonic()
ProcessInstanceDAO
genMonotonic
in interface ProcessInstanceDAO
public BpelDAOConnection getConnection()
getConnection
in interface ProcessInstanceDAO
public java.lang.String toString()
toString
in class java.lang.Object
public java.util.Collection<java.lang.String> getMessageExchangeIds()
getMessageExchangeIds
in interface ProcessInstanceDAO
public java.util.Date getCreateTime()