You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by se...@apache.org on 2009/02/18 00:21:57 UTC
svn commit: r745294 -
/ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
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);