public class ProcessDaoImpl extends HibernateDao implements ProcessDAO, DeferredProcessInstanceCleanable
ProcessDAO
implementation._hobj, _sm
Constructor and Description |
---|
ProcessDaoImpl(SessionManager sm,
HProcess process) |
Modifier and Type | Method and Description |
---|---|
CorrelatorDAO |
addCorrelator(java.lang.String corrid) |
ProcessInstanceDAO |
createInstance(CorrelatorDAO correlator)
Create a new process instance object.
|
int |
deleteInstances(java.util.Collection<HProcessInstance> instances,
java.util.Set<ProcessConf.CLEANUP_CATEGORY> categories) |
int |
deleteInstances(int transactionSize)
Deletes instances and data for this process, the number of rows gets deletes is limited
by the transaction size.
|
void |
deleteProcessAndRoutes()
Deletes only the process and routes without instances.
|
java.util.Collection<ProcessInstanceDAO> |
findInstance(CorrelationKey ckeyValue)
Locates a process instance based on a correlation key.
|
java.util.Collection<ProcessInstanceDAO> |
findInstance(CorrelationKey ckey,
short processInstanceState)
Find instances across all versions of a process that match the correlation key and instance state.
|
java.util.Collection<ProcessInstanceDAO> |
getActiveInstances() |
CorrelatorDAO |
getCorrelator(java.lang.String corrId)
Get a message correlator instance.
|
java.lang.String |
getGuid() |
ProcessInstanceDAO |
getInstance(java.lang.Long iid)
Get a process instance (by identifier).
|
int |
getNumInstances() |
javax.xml.namespace.QName |
getProcessId()
Get the unique process identifier.
|
javax.xml.namespace.QName |
getType()
Get the BPEL process name.
|
long |
getVersion()
Get the process version
|
void |
instanceCompleted(ProcessInstanceDAO instance)
Callback indicating that a process instance has completed its duties.
|
void |
removeRoutes(java.lang.String routeId,
ProcessInstanceDAO target)
Remove the routes with the given Id for all the correlators in the process.
|
deleteByColumn, deleteByIds, equals, getDHandle, getHibernateObj, getId, getSession, hashCode, update
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getId
public ProcessDaoImpl(SessionManager sm, HProcess process)
public javax.xml.namespace.QName getProcessId()
ProcessDAO
getProcessId
in interface ProcessDAO
public ProcessInstanceDAO getInstance(java.lang.Long iid)
ProcessDAO
getInstance
in interface ProcessDAO
iid
- unique instance identifier.public CorrelatorDAO getCorrelator(java.lang.String corrId)
ProcessDAO
getCorrelator
in interface ProcessDAO
corrId
- correlator identifierpublic void removeRoutes(java.lang.String routeId, ProcessInstanceDAO target)
ProcessDAO
removeRoutes
in interface ProcessDAO
public ProcessInstanceDAO createInstance(CorrelatorDAO correlator)
ProcessDAO
createInstance
in interface ProcessDAO
correlator
- instantiating CorrelatorDAO
public java.util.Collection<ProcessInstanceDAO> findInstance(CorrelationKey ckeyValue)
ProcessDAO
findInstance
in interface ProcessDAO
ckeyValue
- correlation keyProcessInstanceDAO
that match correlation key, ordered by dateProcessDAO.findInstance(CorrelationKey)
public void instanceCompleted(ProcessInstanceDAO instance)
ProcessDAO
instanceCompleted
in interface ProcessDAO
instance
- the completed ProcessInstanceDAO
ProcessDAO.instanceCompleted(ProcessInstanceDAO)
public void deleteProcessAndRoutes()
ProcessDAO
deleteProcessAndRoutes
in interface ProcessDAO
public int deleteInstances(int transactionSize)
DeferredProcessInstanceCleanable
deleteInstances
in interface DeferredProcessInstanceCleanable
transactionSize
- the number of rows to deletepublic int deleteInstances(java.util.Collection<HProcessInstance> instances, java.util.Set<ProcessConf.CLEANUP_CATEGORY> categories)
public javax.xml.namespace.QName getType()
ProcessDAO
getType
in interface ProcessDAO
public long getVersion()
ProcessDAO
getVersion
in interface ProcessDAO
public CorrelatorDAO addCorrelator(java.lang.String corrid)
addCorrelator
in interface ProcessDAO
public java.util.Collection<ProcessInstanceDAO> getActiveInstances()
getActiveInstances
in interface ProcessDAO
public int getNumInstances()
getNumInstances
in interface ProcessDAO
public java.lang.String getGuid()
getGuid
in interface ProcessDAO
public java.util.Collection<ProcessInstanceDAO> findInstance(CorrelationKey ckey, short processInstanceState)
findInstance
in interface ProcessDAO
ckey
- Correlation keyprocessInstanceState
- Instance state org.apache.ode.bpel.common.ProcessStateProcessInstanceDAO
that match correlation key, instance state