Author: thomasm
Date: Wed Apr 10 09:00:29 2013
New Revision: 1466393
URL: http://svn.apache.org/r1466393
Log:
OAK-746 Builder for the MongoMK
Modified:
jackrabbit/oak/trunk/oak-it/mk/src/test/java/org/apache/jackrabbit/mk/test/BaseMongoMicroKernelFixture.java
Modified:
jackrabbit/oak/trunk/oak-it/mk/src/test/java/org/apache/jackrabbit/mk/test/BaseMongoMicroKernelFixture.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-it/mk/src/test/java/org/apache/jackrabbit/mk/test/BaseMongoMicroKernelFixture.java?rev=1466393&r1=1466392&r2=1466393&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-it/mk/src/test/java/org/apache/jackrabbit/mk/test/BaseMongoMicroKernelFixture.java
(original)
+++
jackrabbit/oak/trunk/oak-it/mk/src/test/java/org/apache/jackrabbit/mk/test/BaseMongoMicroKernelFixture.java
Wed Apr 10 09:00:29 2013
@@ -69,12 +69,14 @@ public abstract class BaseMongoMicroKern
dropCollections(db);
for (int i = 0; i < cluster.length; i++) {
- cluster[i] = new MongoMK(db, i);
+ cluster[i] = new MongoMK.Builder().
+ setMongoDB(db).setClusterId(i).open();
}
}
@Override
public void syncMicroKernelCluster(MicroKernel... nodes) {
+ // not needed
}
@Override
@@ -91,7 +93,7 @@ public abstract class BaseMongoMicroKern
protected abstract BlobStore getBlobStore(DB db);
- private void dropCollections(DB db) {
+ private static void dropCollections(DB db) {
db.getCollection(MongoBlobStore.COLLECTION_BLOBS).drop();
db.getCollection(DocumentStore.Collection.NODES.name()).drop();
}