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/01/20 20:55:55 UTC
svn commit: r736084 -
/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/CorrelatorDaoImpl.java
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());
}