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/12/17 21:48:37 UTC
svn commit: r604998 -
/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
Author: mriou
Date: Mon Dec 17 12:48:37 2007
New Revision: 604998
URL: http://svn.apache.org/viewvc?rev=604998&view=rev
Log:
Routes were not deleted...
Modified:
ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
Modified: ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java
URL: http://svn.apache.org/viewvc/ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java?rev=604998&r1=604997&r2=604998&view=diff
==============================================================================
--- ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java (original)
+++ ode/trunk/dao-jpa/src/main/java/org/apache/ode/dao/jpa/CorrelatorDAOImpl.java Mon Dec 17 12:48:37 2007
@@ -42,7 +42,7 @@
@Entity
@Table(name="ODE_CORRELATOR")
-public class CorrelatorDAOImpl implements CorrelatorDAO {
+public class CorrelatorDAOImpl extends OpenJPADAO implements CorrelatorDAO {
@Id @Column(name="CORRELATOR_ID")
@GeneratedValue(strategy=GenerationType.AUTO)
@@ -109,9 +109,10 @@
void removeLocalRoutes(String routeGroupId, ProcessInstanceDAO target) {
for (Iterator itr=_routes.iterator(); itr.hasNext(); ) {
MessageRouteDAOImpl mr = (MessageRouteDAOImpl)itr.next();
- if ( mr.getGroupId().equals(routeGroupId) &&
- mr.getTargetInstance().equals(target))
+ if ( mr.getGroupId().equals(routeGroupId) && mr.getTargetInstance().equals(target)) {
itr.remove();
+ getEM().remove(mr);
+ }
}
}
}