org.apache.ode.bpel.memdao
Class ProcessInstanceDaoImpl
java.lang.Object
org.apache.ode.bpel.memdao.ProcessInstanceDaoImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.dao.ProcessInstanceDAO
public class ProcessInstanceDaoImpl
- extends java.lang.Object
- implements org.apache.ode.bpel.dao.ProcessInstanceDAO
A very simple, in-memory implementation of the ProcessInstanceDAO
interface.
| Nested classes/interfaces inherited from interface org.apache.ode.bpel.dao.ProcessInstanceDAO |
org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple |
|
Method Summary |
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)
|
org.apache.ode.bpel.dao.ScopeDAO |
createScope(org.apache.ode.bpel.dao.ScopeDAO parentScope,
java.lang.String scopeType,
int scopeModelId)
|
void |
delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
|
void |
delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories,
boolean deleteMyRoleMex)
|
void |
deleteActivityRecovery(java.lang.String channel)
|
void |
finishCompletion()
|
long |
genMonotonic()
|
int |
getActivityFailureCount()
|
java.util.Date |
getActivityFailureDateTime()
|
java.util.Collection<org.apache.ode.bpel.dao.ActivityRecoveryDAO> |
getActivityRecoveries()
|
org.apache.ode.bpel.dao.BpelDAOConnection |
getConnection()
|
org.apache.ode.bpel.dao.CorrelationSetDAO |
getCorrelationSet(java.lang.String name)
|
java.util.Set<org.apache.ode.bpel.dao.CorrelationSetDAO> |
getCorrelationSets()
|
java.util.Date |
getCreateTime()
|
int |
getEventCount()
|
java.util.List<org.apache.ode.bpel.evt.ProcessInstanceEvent> |
getEvents(int idx,
int count)
|
org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple |
getEventsFirstLastCount()
|
byte[] |
getExecutionState()
|
org.apache.ode.bpel.dao.FaultDAO |
getFault()
|
java.lang.Long |
getInstanceId()
|
org.apache.ode.bpel.dao.CorrelatorDAO |
getInstantiatingCorrelator()
|
java.util.Date |
getLastActiveTime()
|
byte[] |
getMessageExchange(java.lang.String identifier)
|
java.util.Collection<java.lang.String> |
getMessageExchangeIds()
|
short |
getPreviousState()
|
org.apache.ode.bpel.dao.ProcessDAO |
getProcess()
|
org.apache.ode.bpel.dao.ScopeDAO |
getRootScope()
|
org.apache.ode.bpel.dao.ScopeDAO |
getScope(java.lang.Long scopeInstanceId)
|
java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> |
getScopes()
|
java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> |
getScopes(java.lang.String scopeName)
|
java.lang.Object |
getSoup()
|
short |
getState()
|
org.apache.ode.bpel.dao.XmlDataDAO[] |
getVariables(java.lang.String variableName,
int scopeModelId)
|
void |
insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent event)
|
void |
setExecutionState(byte[] bytes)
|
void |
setFault(org.apache.ode.bpel.dao.FaultDAO fault)
|
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)
|
void |
setSoup(java.lang.Object soup)
|
void |
setState(short state)
|
java.lang.String |
toString()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface org.apache.ode.bpel.dao.ProcessInstanceDAO |
getCreateTime |
getVariables
public org.apache.ode.bpel.dao.XmlDataDAO[] getVariables(java.lang.String variableName,
int scopeModelId)
- Specified by:
getVariables in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCorrelationSets
public java.util.Set<org.apache.ode.bpel.dao.CorrelationSetDAO> getCorrelationSets()
- Specified by:
getCorrelationSets in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCorrelationSet
public org.apache.ode.bpel.dao.CorrelationSetDAO getCorrelationSet(java.lang.String name)
- Specified by:
getCorrelationSet in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setFault
public void setFault(javax.xml.namespace.QName name,
java.lang.String explanation,
int lineNo,
int activityId,
org.w3c.dom.Element faultData)
- Specified by:
setFault in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setFault
public void setFault(org.apache.ode.bpel.dao.FaultDAO fault)
- Specified by:
setFault in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getFault
public org.apache.ode.bpel.dao.FaultDAO getFault()
- Specified by:
getFault in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getExecutionState
public byte[] getExecutionState()
- Specified by:
getExecutionState in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getExecutionState()
setExecutionState
public void setExecutionState(byte[] bytes)
- Specified by:
setExecutionState in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getSoup
public java.lang.Object getSoup()
setSoup
public void setSoup(java.lang.Object soup)
getMessageExchange
public byte[] getMessageExchange(java.lang.String identifier)
getProcess
public org.apache.ode.bpel.dao.ProcessDAO getProcess()
- Specified by:
getProcess in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getProcess()
getRootScope
public org.apache.ode.bpel.dao.ScopeDAO getRootScope()
- Specified by:
getRootScope in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getRootScope()
setState
public void setState(short state)
- Specified by:
setState in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.setState(short)
getState
public short getState()
- Specified by:
getState in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getState()
addMessageExchange
public void addMessageExchange(java.lang.String identifier,
byte[] data)
createScope
public org.apache.ode.bpel.dao.ScopeDAO createScope(org.apache.ode.bpel.dao.ScopeDAO parentScope,
java.lang.String scopeType,
int scopeModelId)
- Specified by:
createScope in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getInstanceId
public java.lang.Long getInstanceId()
- Specified by:
getInstanceId in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getScope
public org.apache.ode.bpel.dao.ScopeDAO getScope(java.lang.Long scopeInstanceId)
- Specified by:
getScope in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getScope(java.lang.Long)
getEvents
public java.util.List<org.apache.ode.bpel.evt.ProcessInstanceEvent> getEvents(int idx,
int count)
insertBpelEvent
public void insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent event)
- Specified by:
insertBpelEvent in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent)
getEventCount
public int getEventCount()
getInstantiatingCorrelator
public org.apache.ode.bpel.dao.CorrelatorDAO getInstantiatingCorrelator()
- Specified by:
getInstantiatingCorrelator in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getInstantiatingCorrelator()
getScopes
public java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> getScopes(java.lang.String scopeName)
- Specified by:
getScopes in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getScopes(java.lang.String)
getPreviousState
public short getPreviousState()
- Specified by:
getPreviousState in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getPreviousState()
getLastActiveTime
public java.util.Date getLastActiveTime()
- Specified by:
getLastActiveTime in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.getLastActiveTime()
setLastActiveTime
public void setLastActiveTime(java.util.Date dt)
- Specified by:
setLastActiveTime in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.setLastActiveTime(java.util.Date)
finishCompletion
public void finishCompletion()
- Specified by:
finishCompletion in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
- See Also:
ProcessInstanceDAO.finishCompletion()
delete
public void delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
- Specified by:
delete in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
delete
public void delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories,
boolean deleteMyRoleMex)
- Specified by:
delete in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getScopes
public java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> getScopes()
- Specified by:
getScopes in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getEventsFirstLastCount
public org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
- Specified by:
getEventsFirstLastCount in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getActivityFailureCount
public int getActivityFailureCount()
- Specified by:
getActivityFailureCount in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getActivityFailureDateTime
public java.util.Date getActivityFailureDateTime()
- Specified by:
getActivityFailureDateTime in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getActivityRecoveries
public java.util.Collection<org.apache.ode.bpel.dao.ActivityRecoveryDAO> getActivityRecoveries()
- Specified by:
getActivityRecoveries in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
createActivityRecovery
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)
- Specified by:
createActivityRecovery in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
deleteActivityRecovery
public void deleteActivityRecovery(java.lang.String channel)
- Specified by:
deleteActivityRecovery in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
genMonotonic
public long genMonotonic()
- Specified by:
genMonotonic in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getConnection
public org.apache.ode.bpel.dao.BpelDAOConnection getConnection()
- Specified by:
getConnection in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
toString
public java.lang.String toString()
- Overrides:
toString in class java.lang.Object
getMessageExchangeIds
public java.util.Collection<java.lang.String> getMessageExchangeIds()
- Specified by:
getMessageExchangeIds in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCreateTime
public java.util.Date getCreateTime()