svn commit: r928317 - /ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java

[rr]

Author: rr
Date: Sun Mar 28 01:11:37 2010
New Revision: 928317

URL: http://svn.apache.org/viewvc?rev=928317&view=rev
Log:
Fix for process cleanup

Modified:
    
ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java

Modified: 
ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java?rev=928317&r1=928316&r2=928317&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
 Sun Mar 28 01:11:37 2010
@@ -370,15 +370,17 @@ public class ProcessStoreImpl implements
             if (du != null) {
                 undeployed = toPids(du.getProcessNames(), du.getVersion());
             }
+            
+            for (QName pn : undeployed) {
+                fireEvent(new 
ProcessStoreEvent(ProcessStoreEvent.Type.UNDEPLOYED, pn, du.getName()));
+                __log.info(__msgs.msgProcessUndeployed(pn));
+            }
+            
             _processes.keySet().removeAll(undeployed);
         } finally {
             _rw.writeLock().unlock();
         }
 
-        for (QName pn : undeployed) {
-            fireEvent(new ProcessStoreEvent(ProcessStoreEvent.Type.UNDEPLOYED, 
pn, du.getName()));
-            __log.info(__msgs.msgProcessUndeployed(pn));
-        }        
         return undeployed;
     }