svn commit: r665753 - /ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java

[mriou]

Author: mriou
Date: Mon Jun  9 09:37:18 2008
New Revision: 665753

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

Modified:
    
ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java

Modified: 
ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
URL: 
http://svn.apache.org/viewvc/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java?rev=665753&r1=665752&r2=665753&view=diff
==============================================================================
--- 
ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java 
(original)
+++ 
ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java 
Mon Jun  9 09:37:18 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._correlatorId = :corrkey")
         })
 public class CorrelatorDAOImpl extends OpenJPADAO implements CorrelatorDAO {
 
@@ -93,7 +93,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);
         else return null;