public class CorrelatorDAOImpl extends OpenJPADAO implements CorrelatorDAO
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DELETE_CORRELATORS_BY_PROCESS |
| Constructor and Description |
|---|
CorrelatorDAOImpl() |
CorrelatorDAOImpl(java.lang.String correlatorKey,
ProcessDAOImpl process) |
| Modifier and Type | Method and Description |
|---|---|
void |
addRoute(java.lang.String routeGroupId,
ProcessInstanceDAO target,
int index,
CorrelationKeySet correlationKeySet,
java.lang.String routePolicy)
Add a route from the given correlation key to the given process instance.
|
boolean |
checkRoute(CorrelationKeySet correlationKeySet)
Check if corresponding key set is free to register (see ODE-804)
|
MessageExchangeDAO |
dequeueMessage(CorrelationKeySet correlationKeySet)
Dequeue a message exchange matching a correlationKey constraint.
|
void |
enqueueMessage(MessageExchangeDAO mex,
CorrelationKeySet correlationKeySet)
Enqueue a message exchange to the queue with a set of correlation keys.
|
java.util.List<MessageRouteDAO> |
findRoute(CorrelationKeySet correlationKeySet) |
java.util.List<MessageRouteDAO> |
findRoute(CorrelationKeySet correlationKeySet,
boolean isCorrleationKeySetPreInitialized)
Find a route matching the given correlation key set.
|
java.util.Collection<CorrelatorMessageDAO> |
getAllMessages() |
java.util.Collection<MessageRouteDAO> |
getAllRoutes() |
java.lang.String |
getCorrelatorId()
Get the correlator identifier.
|
void |
removeRoutes(java.lang.String routeGroupId,
ProcessInstanceDAO target)
Remove all routes with the given route-group identifier.
|
void |
setCorrelatorId(java.lang.String newId) |
batchUpdateByIds, getConn, getEM, getSingleResultpublic static final java.lang.String DELETE_CORRELATORS_BY_PROCESS
public CorrelatorDAOImpl()
public CorrelatorDAOImpl(java.lang.String correlatorKey,
ProcessDAOImpl process)
public void addRoute(java.lang.String routeGroupId,
ProcessInstanceDAO target,
int index,
CorrelationKeySet correlationKeySet,
java.lang.String routePolicy)
CorrelatorDAOaddRoute in interface CorrelatorDAOrouteGroupId - identifier of the group of routes to which this route belongstarget - target process instanceindex - relative order in which the route should be consideredpublic MessageExchangeDAO dequeueMessage(CorrelationKeySet correlationKeySet)
CorrelatorDAOdequeueMessage in interface CorrelatorDAOpublic void enqueueMessage(MessageExchangeDAO mex, CorrelationKeySet correlationKeySet)
CorrelatorDAOenqueueMessage in interface CorrelatorDAOmex - message exchangepublic java.util.Collection<CorrelatorMessageDAO> getAllMessages()
getAllMessages in interface CorrelatorDAOpublic java.util.List<MessageRouteDAO> findRoute(CorrelationKeySet correlationKeySet)
findRoute in interface CorrelatorDAOCorrelatorDAO.findRoute(CorrelationKeySet correlationKeySet,boolean isCorrleationKeySetPreInitialized)public java.lang.String getCorrelatorId()
CorrelatorDAOgetCorrelatorId in interface CorrelatorDAOpublic void setCorrelatorId(java.lang.String newId)
setCorrelatorId in interface CorrelatorDAOpublic void removeRoutes(java.lang.String routeGroupId,
ProcessInstanceDAO target)
CorrelatorDAOremoveRoutes in interface CorrelatorDAOpublic java.util.Collection<MessageRouteDAO> getAllRoutes()
getAllRoutes in interface CorrelatorDAOpublic boolean checkRoute(CorrelationKeySet correlationKeySet)
CorrelatorDAOcheckRoute in interface CorrelatorDAOpublic java.util.List<MessageRouteDAO> findRoute(CorrelationKeySet correlationKeySet, boolean isCorrleationKeySetPreInitialized)
CorrelatorDAOfindRoute in interface CorrelatorDAOcorrelationKeySet - correlation key