Author: seanahn
Date: Tue Feb 17 23:21:57 2009
New Revision: 745294

URL: http://svn.apache.org/viewvc?rev=745294&view=rev
Log:
Fixed 'one' or null route policy

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

Modified: 
ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java?rev=745294&r1=745293&r2=745294&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
 Tue Feb 17 23:21:57 2009
@@ -101,8 +101,8 @@
                List<ProcessInstanceDAO> targets = new 
ArrayList<ProcessInstanceDAO>();
             for (int i = 0; i < routes.size(); i++) {
                MessageRouteDAO route = routes.get(i);
-               if ("all".equals(route.getRoute()) || 
-                               ("one".equals(route.getRoute()) && 
!targets.contains(route.getTargetInstance()))) {
+               if ("all".equals(route.getRoute()) ||
+                               (!"all".equals(route.getRoute()) && 
!targets.contains(route.getTargetInstance()))) {
                        targets.add(route.getTargetInstance());
                } else {
                        routes.remove(i);


Reply via email to