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, waitgetCreateTimepublic XmlDataDAO[] getVariables(java.lang.String variableName, int scopeModelId)
ProcessInstanceDAOgetVariables in interface ProcessInstanceDAOpublic java.util.Set<CorrelationSetDAO> getCorrelationSets()
ProcessInstanceDAOgetCorrelationSets in interface ProcessInstanceDAOSet of CorrelationSetDAO objectspublic CorrelationSetDAO getCorrelationSet(java.lang.String name)
ProcessInstanceDAOgetCorrelationSet in interface ProcessInstanceDAOCorrelationSetDAO objectpublic void setFault(javax.xml.namespace.QName name,
java.lang.String explanation,
int lineNo,
int activityId,
org.w3c.dom.Element faultData)
setFault in interface ProcessInstanceDAOpublic void setFault(FaultDAO fault)
ProcessInstanceDAOnull if no fault occurred or if all faults are caught and
processed.setFault in interface ProcessInstanceDAOfault - the faultpublic FaultDAO getFault()
ProcessInstanceDAOnull if no fault occurred or if all faults are caught and
processed.getFault in interface ProcessInstanceDAOpublic byte[] getExecutionState()
ProcessInstanceDAOgetExecutionState in interface ProcessInstanceDAOProcessInstanceDAO.getExecutionState()public void setExecutionState(byte[] bytes)
ProcessInstanceDAOsetExecutionState in interface ProcessInstanceDAObytes - execuction statepublic java.lang.Object getSoup()
public void setSoup(java.lang.Object soup)
public byte[] getMessageExchange(java.lang.String identifier)
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 void addMessageExchange(java.lang.String identifier,
byte[] data)
public ScopeDAO createScope(ScopeDAO parentScope, java.lang.String scopeType, int scopeModelId)
ProcessInstanceDAOcreateScope in interface ProcessInstanceDAOparentScope - parent scope of the new scope, or null if this is the
root scope.scopeType - scope namepublic java.lang.Long getInstanceId()
ProcessInstanceDAOgetInstanceId in interface ProcessInstanceDAOpublic ScopeDAO getScope(java.lang.Long scopeInstanceId)
ProcessInstanceDAOgetScope in interface ProcessInstanceDAOProcessInstanceDAO.getScope(java.lang.Long)public java.util.List<ProcessInstanceEvent> getEvents(int idx, int count)
public void insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAOinsertBpelEvent in interface ProcessInstanceDAOevent - BPEL eventProcessInstanceDAO.insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent)public int getEventCount()
public CorrelatorDAO getInstantiatingCorrelator()
ProcessInstanceDAOgetInstantiatingCorrelator in interface ProcessInstanceDAOProcessInstanceDAO.getInstantiatingCorrelator()public java.util.Collection<ScopeDAO> getScopes(java.lang.String scopeName)
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOProcessInstanceDAO.getScopes(java.lang.String)public short getPreviousState()
ProcessInstanceDAOgetPreviousState in interface ProcessInstanceDAOProcessInstanceDAO.getPreviousState()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 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 java.util.Collection<ScopeDAO> getScopes()
ProcessInstanceDAOgetScopes in interface ProcessInstanceDAOpublic ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAOgetEventsFirstLastCount in interface ProcessInstanceDAOpublic 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)
ProcessInstanceDAOdeleteActivityRecovery in interface ProcessInstanceDAOpublic long genMonotonic()
ProcessInstanceDAOgenMonotonic in interface ProcessInstanceDAOpublic BpelDAOConnection getConnection()
getConnection in interface ProcessInstanceDAOpublic java.lang.String toString()
toString in class java.lang.Objectpublic java.util.Collection<java.lang.String> getMessageExchangeIds()
getMessageExchangeIds in interface ProcessInstanceDAOpublic java.util.Date getCreateTime()