org.apache.ode.dao.jpa
Class CorrelatorDAOImpl

java.lang.Object
  extended by org.apache.ode.dao.jpa.OpenJPADAO
      extended by 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


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, 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 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

DELETE_CORRELATORS_BY_PROCESS

public static final java.lang.String DELETE_CORRELATORS_BY_PROCESS
See Also:
Constant Field Values
Constructor Detail

CorrelatorDAOImpl

public CorrelatorDAOImpl()

CorrelatorDAOImpl

public CorrelatorDAOImpl(java.lang.String correlatorKey,
                         ProcessDAOImpl process)
Method Detail

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