jackrabbit-oak-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mreut...@apache.org
Subject svn commit: r1452823 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java
Date Tue, 05 Mar 2013 14:54:40 GMT
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;



Mime
View raw message