svn commit: r1452823 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java

[mreutegg]

Author: mreutegg
Date: Tue Mar  5 14:54:40 2013
New Revision: 1452823

URL: http://svn.apache.org/r1452823
Log:
OAK-670: Log error when ChangeProcessor fails with exception

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java?rev=1452823&r1=1452822&r2=1452823&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java
 Tue Mar  5 14:54:40 2013
@@ -39,11 +39,16 @@ import org.apache.jackrabbit.oak.spi.sta
 import org.apache.jackrabbit.oak.spi.state.NodeState;
 import org.apache.jackrabbit.oak.spi.state.NodeStateDiff;
 import org.apache.jackrabbit.oak.spi.state.NodeStateUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * TODO document
  */
 class ChangeProcessor implements Runnable {
+
+    private static final Logger log = 
LoggerFactory.getLogger(ChangeProcessor.class);
+
     private final ObservationManagerImpl observationManager;
     private final NamePathMapper namePathMapper;
     private final ChangeExtractor changeExtractor;
@@ -111,6 +116,8 @@ class ChangeProcessor implements Runnabl
             if (!stopping) {
                 diff.sendEvents();
             }
+        } catch (Exception e) {
+            log.error("Unable to generate or send events", e);
         } finally {
             synchronized (this) {
                 running = false;