svn commit: r664187 - /ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java

[mriou]

Author: mriou
Date: Fri Jun  6 16:08:14 2008
New Revision: 664187

URL: http://svn.apache.org/viewvc?rev=664187&view=rev
Log:
Too restrictive query, tweaking to avoid breaking sending messages to retired 
instances.

Modified:
    
ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java

Modified: 
ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java?rev=664187&r1=664186&r2=664187&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.1/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
 Fri Jun  6 16:08:14 2008
@@ -38,7 +38,7 @@
             "FROM MessageRouteDAOImpl as route " +
             "WHERE route._correlationKey = :ckey " +
                    "and route._correlator._process._processType = :ptype " +
-                   "and route._correlator._correlatorId = :corrid")
+                   "and route._correlator._correlatorKey = :corrkey")
         })
 public class CorrelatorDAOImpl extends OpenJPADAO implements CorrelatorDAO {
 
@@ -92,7 +92,7 @@
         Query qry = getEM().createNamedQuery("RouteByCKey");
         qry.setParameter("ckey", correlationKey.toCanonicalString());
         qry.setParameter("ptype", _process.getType().toString());
-        qry.setParameter("corrid", _correlatorId);
+        qry.setParameter("corrkey", _correlatorKey);
         List<MessageRouteDAO> routes = (List<MessageRouteDAO>) 
qry.getResultList();
         if (routes.size() > 0) {
           return routes.get(0);