org.apache.ode.dao.jpa
Class CorrelatorDAOImpl
java.lang.Object
org.apache.ode.dao.jpa.OpenJPADAO
org.apache.ode.dao.jpa.CorrelatorDAOImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.dao.CorrelatorDAO
public class CorrelatorDAOImpl
- extends OpenJPADAO
- implements org.apache.ode.bpel.dao.CorrelatorDAO
Method Summary |
void |
addRoute(java.lang.String routeGroupId,
org.apache.ode.bpel.dao.ProcessInstanceDAO target,
int index,
org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet,
java.lang.String routePolicy)
|
boolean |
checkRoute(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
|
org.apache.ode.bpel.dao.MessageExchangeDAO |
dequeueMessage(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
|
void |
enqueueMessage(org.apache.ode.bpel.dao.MessageExchangeDAO mex,
org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
|
java.util.List<org.apache.ode.bpel.dao.MessageRouteDAO> |
findRoute(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
|
java.util.Collection<org.apache.ode.bpel.dao.CorrelatorMessageDAO> |
getAllMessages()
|
java.util.Collection<org.apache.ode.bpel.dao.MessageRouteDAO> |
getAllRoutes()
|
java.lang.String |
getCorrelatorId()
|
void |
removeRoutes(java.lang.String routeGroupId,
org.apache.ode.bpel.dao.ProcessInstanceDAO target)
|
void |
setCorrelatorId(java.lang.String newId)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DELETE_CORRELATORS_BY_PROCESS
public static final java.lang.String DELETE_CORRELATORS_BY_PROCESS
- See Also:
- Constant Field Values
CorrelatorDAOImpl
public CorrelatorDAOImpl()
CorrelatorDAOImpl
public CorrelatorDAOImpl(java.lang.String correlatorKey,
ProcessDAOImpl process)
addRoute
public void addRoute(java.lang.String routeGroupId,
org.apache.ode.bpel.dao.ProcessInstanceDAO target,
int index,
org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet,
java.lang.String routePolicy)
- Specified by:
addRoute
in interface org.apache.ode.bpel.dao.CorrelatorDAO
dequeueMessage
public org.apache.ode.bpel.dao.MessageExchangeDAO dequeueMessage(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
- Specified by:
dequeueMessage
in interface org.apache.ode.bpel.dao.CorrelatorDAO
enqueueMessage
public void enqueueMessage(org.apache.ode.bpel.dao.MessageExchangeDAO mex,
org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
- Specified by:
enqueueMessage
in interface org.apache.ode.bpel.dao.CorrelatorDAO
getAllMessages
public java.util.Collection<org.apache.ode.bpel.dao.CorrelatorMessageDAO> getAllMessages()
- Specified by:
getAllMessages
in interface org.apache.ode.bpel.dao.CorrelatorDAO
findRoute
public java.util.List<org.apache.ode.bpel.dao.MessageRouteDAO> findRoute(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
- Specified by:
findRoute
in interface org.apache.ode.bpel.dao.CorrelatorDAO
getCorrelatorId
public java.lang.String getCorrelatorId()
- Specified by:
getCorrelatorId
in interface org.apache.ode.bpel.dao.CorrelatorDAO
setCorrelatorId
public void setCorrelatorId(java.lang.String newId)
- Specified by:
setCorrelatorId
in interface org.apache.ode.bpel.dao.CorrelatorDAO
removeRoutes
public void removeRoutes(java.lang.String routeGroupId,
org.apache.ode.bpel.dao.ProcessInstanceDAO target)
- Specified by:
removeRoutes
in interface org.apache.ode.bpel.dao.CorrelatorDAO
getAllRoutes
public java.util.Collection<org.apache.ode.bpel.dao.MessageRouteDAO> getAllRoutes()
- Specified by:
getAllRoutes
in interface org.apache.ode.bpel.dao.CorrelatorDAO
checkRoute
public boolean checkRoute(org.apache.ode.bpel.common.CorrelationKeySet correlationKeySet)
- Specified by:
checkRoute
in interface org.apache.ode.bpel.dao.CorrelatorDAO