Index: oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java	(date 1345653720000)
+++ oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java	(revision )
@@ -96,13 +96,18 @@
     @Override
     public void run() {
         running = true;
+        try{
-        EventGeneratingNodeStateDiff diff = new EventGeneratingNodeStateDiff();
-        changeExtractor.getChanges(diff);
-        if (!stopping) {
-            diff.sendEvents();
-        }
+            EventGeneratingNodeStateDiff diff = new EventGeneratingNodeStateDiff();
+            changeExtractor.getChanges(diff);
+            if (!stopping) {
+                diff.sendEvents();
+            }
+        }finally{
+            if(stopping){
-        stopped.countDown();
+                stopped.countDown();
+            }
-        running = false;
+            running = false;
+        }
     }
 
     //------------------------------------------------------------< private >---