@Entity public class ProcessDAOImpl extends OpenJPADAO implements ProcessDAO
Constructor and Description |
---|
ProcessDAOImpl() |
ProcessDAOImpl(javax.xml.namespace.QName pid,
javax.xml.namespace.QName type,
java.lang.String guid,
long version) |
Modifier and Type | Method and Description |
---|---|
CorrelatorDAO |
addCorrelator(java.lang.String correlator) |
ProcessInstanceDAO |
createInstance(CorrelatorDAO instantiatingCorrelator)
Create a new process instance object.
|
ProcessInstanceDAO |
createInstance(CorrelatorDAO instantiatingCorrelator,
MessageExchangeDAO mex) |
void |
deleteProcessAndRoutes()
Deletes only the process and routes without instances.
|
java.util.Collection<ProcessInstanceDAO> |
findInstance(CorrelationKey ckey)
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 correlatorId)
Get a message correlator instance.
|
java.lang.String |
getGuid() |
java.io.Serializable |
getId() |
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.
|
void |
setId(java.lang.Long id) |
batchUpdateByIds, getConn, getEM, getSingleResult
public ProcessDAOImpl()
public ProcessDAOImpl(javax.xml.namespace.QName pid, javax.xml.namespace.QName type, java.lang.String guid, long version)
public java.io.Serializable getId()
public void setId(java.lang.Long id)
public CorrelatorDAO addCorrelator(java.lang.String correlator)
addCorrelator
in interface ProcessDAO
public CorrelatorDAO getCorrelator(java.lang.String correlatorId)
ProcessDAO
getCorrelator
in interface ProcessDAO
correlatorId
- correlator identifierpublic ProcessInstanceDAO createInstance(CorrelatorDAO instantiatingCorrelator)
ProcessDAO
createInstance
in interface ProcessDAO
instantiatingCorrelator
- instantiating CorrelatorDAO
public ProcessInstanceDAO createInstance(CorrelatorDAO instantiatingCorrelator, MessageExchangeDAO mex)
public java.util.Collection<ProcessInstanceDAO> findInstance(CorrelationKey ckey)
ProcessDAO
findInstance
in interface ProcessDAO
ckey
- correlation keyProcessInstanceDAO
that match correlation key, ordered by datepublic ProcessInstanceDAO getInstance(java.lang.Long iid)
ProcessDAO
getInstance
in interface ProcessDAO
iid
- unique instance identifier.public javax.xml.namespace.QName getProcessId()
ProcessDAO
getProcessId
in interface ProcessDAO
public javax.xml.namespace.QName getType()
ProcessDAO
getType
in interface ProcessDAO
public void deleteProcessAndRoutes()
ProcessDAO
deleteProcessAndRoutes
in interface ProcessDAO
public int getNumInstances()
getNumInstances
in interface ProcessDAO
public long getVersion()
ProcessDAO
getVersion
in interface ProcessDAO
public void instanceCompleted(ProcessInstanceDAO instance)
ProcessDAO
instanceCompleted
in interface ProcessDAO
instance
- the completed ProcessInstanceDAO
public void removeRoutes(java.lang.String routeId, ProcessInstanceDAO target)
ProcessDAO
removeRoutes
in interface ProcessDAO
public java.lang.String getGuid()
getGuid
in interface ProcessDAO
public java.util.Collection<ProcessInstanceDAO> getActiveInstances()
getActiveInstances
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