svn commit: r1765983 - /jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java

[mreutegg]

Author: mreutegg
Date: Fri Oct 21 10:18:13 2016
New Revision: 1765983

URL: http://svn.apache.org/viewvc?rev=1765983&view=rev
Log:
OAK-4976: AcquireRecoveryLockTest fails occasionally

Modified:
    
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java?rev=1765983&r1=1765982&r2=1765983&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/AcquireRecoveryLockTest.java
 Fri Oct 21 10:18:13 2016
@@ -25,6 +25,7 @@ import org.apache.jackrabbit.oak.plugins
 import org.apache.jackrabbit.oak.plugins.document.ClusterNodeInfoDocument;
 import org.apache.jackrabbit.oak.plugins.document.DocumentMK;
 import org.apache.jackrabbit.oak.stats.Clock;
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -37,9 +38,19 @@ public class AcquireRecoveryLockTest ext
 
     private Clock clock = new Clock.Virtual();
 
+    private MongoDocumentStore store;
+
     @Before
     public void before() throws Exception {
         clock.waitUntil(System.currentTimeMillis());
+        store = new MongoDocumentStore(
+                connectionFactory.getConnection().getDB(),
+                new DocumentMK.Builder());
+    }
+
+    @After
+    public void after() {
+        store.dispose();
     }
 
     @Override
@@ -56,8 +67,6 @@ public class AcquireRecoveryLockTest ext
     // OAK-4131
     @Test
     public void recoveryBy() throws Exception {
-        MongoDocumentStore store = new MongoDocumentStore(
-                mongoConnection.getDB(), new DocumentMK.Builder());
         MongoMissingLastRevSeeker seeker = new 
MongoMissingLastRevSeeker(store, getTestClock());
         List<ClusterNodeInfoDocument> infoDocs = 
newArrayList(seeker.getAllClusters());
         assertEquals(1, infoDocs.size());