You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by md...@apache.org on 2013/10/30 09:36:04 UTC
svn commit: r1537008 -
/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/observation/ChangeProcessor.java
Author: mduerig
Date: Wed Oct 30 08:36:03 2013
New Revision: 1537008
URL: http://svn.apache.org/r1537008
Log:
OAK-144 Implement observation
Set thread's interrupted state on InterruptedException
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=1537008&r1=1537007&r2=1537008&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 Wed Oct 30 08:36:03 2013
@@ -115,6 +115,7 @@ public class ChangeProcessor {
thread.join();
} catch (InterruptedException e) {
log.warn("Interruption while waiting for the observation thread to terminate", e);
+ Thread.currentThread().interrupt();
}
}
}