ode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sean...@apache.org
Subject svn commit: r736084 - /ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java
Date Tue, 20 Jan 2009 19:55:55 GMT
Author: seanahn
Date: Tue Jan 20 11:55:55 2009
New Revision: 736084

URL: http://svn.apache.org/viewvc?rev=736084&view=rev
Log:
ODE-442, route="one" may route a message to the same instance multiple times

Modified:
    ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java

Modified: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java?rev=736084&r1=736083&r2=736084&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java
(original)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java
Tue Jan 20 11:55:55 2009
@@ -77,7 +77,7 @@
         for (MessageRouteDaoImpl we : _routes) {
             assert we._ckeySet != null;
 
-            if( keySet.isRoutableTo(we._ckeySet, "all".equals(we.getRoute())) ) {
+            if( !targets.contains(we.getTargetInstance()) && keySet.isRoutableTo(we._ckeySet,
"all".equals(we.getRoute())) ) {
                 routes.add(we);
                 targets.add(we.getTargetInstance());
             }



Mime
View raw message