|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.dao.jpa.OpenJPADAO
org.apache.ode.dao.jpa.CorrelatorDAOImpl
public class CorrelatorDAOImpl
Field Summary | |
---|---|
static java.lang.String |
DELETE_CORRELATORS_BY_PROCESS
|
Constructor Summary | |
---|---|
CorrelatorDAOImpl()
|
|
CorrelatorDAOImpl(java.lang.String correlatorKey,
ProcessDAOImpl process)
|
Method Summary | |
---|---|
void |
addRoute(java.lang.String routeGroupId,
ProcessInstanceDAO target,
int index,
CorrelationKey correlationKey)
Add a route from the given correlation key to the given process instance. |
MessageExchangeDAO |
dequeueMessage(CorrelationKey correlationKey)
Dequeue a message exchange matching a correlationKey constraint. |
void |
enqueueMessage(MessageExchangeDAO mex,
CorrelationKey[] correlationKeys)
Enqueue a message exchange to the queue with a set of correlation keys. |
MessageRouteDAO |
findRoute(CorrelationKey correlationKey)
Find a route matching the given correlation key. |
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. |
Methods inherited from class org.apache.ode.dao.jpa.OpenJPADAO |
---|
batchUpdateByIds, getConn, getEM, getSingleResult |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String DELETE_CORRELATORS_BY_PROCESS
Constructor Detail |
---|
public CorrelatorDAOImpl()
public CorrelatorDAOImpl(java.lang.String correlatorKey, ProcessDAOImpl process)
Method Detail |
---|
public void addRoute(java.lang.String routeGroupId, ProcessInstanceDAO target, int index, CorrelationKey correlationKey)
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 consideredcorrelationKey
- correlation key to matchpublic MessageExchangeDAO dequeueMessage(CorrelationKey correlationKey)
CorrelatorDAO
dequeueMessage
in interface CorrelatorDAO
correlationKey
- correlation correlationKey constraint
public void enqueueMessage(MessageExchangeDAO mex, CorrelationKey[] correlationKeys)
CorrelatorDAO
enqueueMessage
in interface CorrelatorDAO
mex
- message exchangecorrelationKeys
- pre-computed set of correlation keys for this messagepublic MessageRouteDAO findRoute(CorrelationKey correlationKey)
CorrelatorDAO
findRoute
in interface CorrelatorDAO
correlationKey
- correlation key
public java.lang.String getCorrelatorId()
CorrelatorDAO
getCorrelatorId
in interface CorrelatorDAO
public void removeRoutes(java.lang.String routeGroupId, ProcessInstanceDAO target)
CorrelatorDAO
removeRoutes
in interface CorrelatorDAO
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |