|
|||||||||
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,
CorrelationKeySet correlationKeySet,
java.lang.String routePolicy)
Add a route from the given correlation key to the given process instance. |
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)
Find a route matching the given correlation key. |
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)
|
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, 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)
CorrelatorDAO
findRoute
in interface CorrelatorDAO
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
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |