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> |
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, updateclone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitgetIdpublic ProcessDaoImpl(SessionManager sm, HProcess process)
public javax.xml.namespace.QName getProcessId()
ProcessDAOgetProcessId in interface ProcessDAOpublic ProcessInstanceDAO getInstance(java.lang.Long iid)
ProcessDAOgetInstance in interface ProcessDAOiid - unique instance identifier.public CorrelatorDAO getCorrelator(java.lang.String corrId)
ProcessDAOgetCorrelator in interface ProcessDAOcorrId - correlator identifierpublic void removeRoutes(java.lang.String routeId,
ProcessInstanceDAO target)
ProcessDAOremoveRoutes in interface ProcessDAOpublic ProcessInstanceDAO createInstance(CorrelatorDAO correlator)
ProcessDAOcreateInstance in interface ProcessDAOcorrelator - instantiating CorrelatorDAOpublic java.util.Collection<ProcessInstanceDAO> findInstance(CorrelationKey ckeyValue)
ProcessDAOfindInstance in interface ProcessDAOckeyValue - correlation keyProcessInstanceDAO that match correlation key, ordered by dateProcessDAO.findInstance(CorrelationKey)public void instanceCompleted(ProcessInstanceDAO instance)
ProcessDAOinstanceCompleted in interface ProcessDAOinstance - the completed ProcessInstanceDAOProcessDAO.instanceCompleted(ProcessInstanceDAO)public void deleteProcessAndRoutes()
ProcessDAOdeleteProcessAndRoutes in interface ProcessDAOpublic int deleteInstances(int transactionSize)
DeferredProcessInstanceCleanabledeleteInstances in interface DeferredProcessInstanceCleanabletransactionSize - 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()
ProcessDAOgetType in interface ProcessDAOpublic long getVersion()
ProcessDAOgetVersion in interface ProcessDAOpublic CorrelatorDAO addCorrelator(java.lang.String corrid)
addCorrelator in interface ProcessDAOpublic java.util.Collection<ProcessInstanceDAO> getActiveInstances()
getActiveInstances in interface ProcessDAOpublic int getNumInstances()
getNumInstances in interface ProcessDAOpublic java.lang.String getGuid()
getGuid in interface ProcessDAO