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

[seanahn]

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