|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.daohib.bpel.HibernateDao
org.apache.ode.daohib.bpel.ProcessInstanceDaoImpl
public class ProcessInstanceDaoImpl
Hibernate-based ProcessInstanceDAO
implementation.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.ode.bpel.dao.ProcessInstanceDAO |
---|
ProcessInstanceDAO.EventsFirstLastCountTuple |
Field Summary |
---|
Fields inherited from class org.apache.ode.daohib.bpel.HibernateDao |
---|
_hobj, _sm |
Constructor Summary | |
---|---|
ProcessInstanceDaoImpl(SessionManager sm,
HProcessInstance instance)
|
Method Summary | |
---|---|
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. |
boolean |
delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
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. |
int |
getExecutionStateCounter()
|
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). |
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 |
setExecutionStateCounter(int stateCounter)
|
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. |
Methods inherited from class org.apache.ode.daohib.bpel.HibernateDao |
---|
equals, getDHandle, getHibernateObj, getSession, hashCode, update |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ProcessInstanceDaoImpl(SessionManager sm, HProcessInstance instance)
Method Detail |
---|
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 name
public 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 boolean delete(java.util.Set<ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
ProcessInstanceDAO
delete
in interface ProcessInstanceDAO
public void insertBpelEvent(ProcessInstanceEvent event)
ProcessInstanceDAO
insertBpelEvent
in interface ProcessInstanceDAO
event
- BPEL eventpublic ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
ProcessInstanceDAO
getEventsFirstLastCount
in interface ProcessInstanceDAO
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 int getExecutionStateCounter()
getExecutionStateCounter
in interface ProcessInstanceDAO
public void setExecutionStateCounter(int stateCounter)
setExecutionStateCounter
in interface ProcessInstanceDAO
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |