Skip to content

Commit a4dea64

Browse files
Update unit test
1 parent c22fa8f commit a4dea64

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

Diff for: src/test/java/test/elasticsearch/plugin/river/mongodb/simple/RiverMongoDropCollectionTest.java

+3
Original file line numberDiff line numberDiff line change
@@ -103,8 +103,11 @@ public void testDropCollection() throws Throwable {
103103
.prepareTypesExists(getIndex())
104104
.setTypes(getDatabase()).execute().actionGet()
105105
.isExists(), equalTo(true));
106+
String collectionName = mongoCollection.getName();
106107
mongoCollection.drop();
107108
Thread.sleep(wait);
109+
assertThat(mongoDB.collectionExists(collectionName), equalTo(false));
110+
Thread.sleep(wait);
108111
refreshIndex();
109112
assertThat(
110113
getNode().client().admin().indices()

0 commit comments

Comments
 (0)