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);