@Entity 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, getSingleResult
public 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)
CorrelatorDAO
addRoute
in interface CorrelatorDAO
routeGroupId
- 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)
CorrelatorDAO
dequeueMessage
in interface CorrelatorDAO
public void enqueueMessage(MessageExchangeDAO mex, CorrelationKeySet correlationKeySet)
CorrelatorDAO
enqueueMessage
in interface CorrelatorDAO
mex
- message exchangepublic java.util.Collection<CorrelatorMessageDAO> getAllMessages()
getAllMessages
in interface CorrelatorDAO
public java.util.List<MessageRouteDAO> findRoute(CorrelationKeySet correlationKeySet)
findRoute
in interface CorrelatorDAO
CorrelatorDAO.findRoute(CorrelationKeySet correlationKeySet,boolean isCorrleationKeySetPreInitialized)
public java.lang.String getCorrelatorId()
CorrelatorDAO
getCorrelatorId
in interface CorrelatorDAO
public void setCorrelatorId(java.lang.String newId)
setCorrelatorId
in interface CorrelatorDAO
public void removeRoutes(java.lang.String routeGroupId, ProcessInstanceDAO target)
CorrelatorDAO
removeRoutes
in interface CorrelatorDAO
public java.util.Collection<MessageRouteDAO> getAllRoutes()
getAllRoutes
in interface CorrelatorDAO
public boolean checkRoute(CorrelationKeySet correlationKeySet)
CorrelatorDAO
checkRoute
in interface CorrelatorDAO
public java.util.List<MessageRouteDAO> findRoute(CorrelationKeySet correlationKeySet, boolean isCorrleationKeySetPreInitialized)
CorrelatorDAO
findRoute
in interface CorrelatorDAO
correlationKeySet
- correlation key