You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2007/04/12 00:00:26 UTC
svn commit: r527697 -
/incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
Author: mriou
Date: Wed Apr 11 15:00:25 2007
New Revision: 527697
URL: http://svn.apache.org/viewvc?view=rev&rev=527697
Log:
delete fix
Modified:
incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
Modified: incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java?view=diff&rev=527697&r1=527696&r2=527697
==============================================================================
--- incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java (original)
+++ incubator/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java Wed Apr 11 15:00:25 2007
@@ -128,13 +128,19 @@
}
public void deleteActivityRecovery(String channel) {
+ ActivityRecoveryDAOImpl toRemove = null;
for (ActivityRecoveryDAO _recovery : _recoveries) {
ActivityRecoveryDAOImpl arElement = (ActivityRecoveryDAOImpl) _recovery;
if (arElement.getChannel().equals(channel)) {
- getEM().remove(arElement);
- return;
+ toRemove = arElement;
+ break;
}
}
+ if (toRemove != null) {
+ getEM().remove(toRemove);
+ _recoveries.remove(toRemove);
+ }
+
}
public void finishCompletion() {