svn commit: r1758561 - /jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java

[mreutegg]

Author: mreutegg
Date: Wed Aug 31 09:26:22 2016
New Revision: 1758561

URL: http://svn.apache.org/viewvc?rev=1758561&view=rev
Log:
OAK-4724: Prefetch external changes

Update test to use a proper thread pool

Modified:
    
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java

Modified: 
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java?rev=1758561&r1=1758560&r2=1758561&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ObservationQueueTest.java
 Wed Aug 31 09:26:22 2016
@@ -21,6 +21,7 @@ import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Random;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
@@ -150,6 +151,7 @@ public class ObservationQueueTest extend
                         .setPersistentCache("target/persistentCache" + 
clusterNodeId + ",time,size=128")
                         .setJournalCache("target/journalCache" + clusterNodeId 
+ ",time,size=128")
                         .memoryCacheSize(128 * MB)
+                        .setExecutor(Executors.newCachedThreadPool())
                         .getNodeStore();
             }
         };