DATAMONGO-2322 - Polishing.
Suspend change streams tests relying heavily on timing.
This commit is contained in:
@@ -50,6 +50,7 @@ import org.bson.Document;
|
||||
import org.bson.types.ObjectId;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
import org.junit.rules.ExpectedException;
|
||||
@@ -1262,6 +1263,7 @@ public class ReactiveMongoTemplateTests {
|
||||
}
|
||||
|
||||
@Test // DATAMONGO-1803
|
||||
@Ignore("Heavily relying on timing assumptions. Cannot test message resumption properly. Too much race for too little time in between.")
|
||||
public void changeStreamEventsShouldBeResumedCorrectly() throws InterruptedException {
|
||||
|
||||
Assumptions.assumeThat(ReplicaSet.required().runsAsReplicaSet()).isTrue();
|
||||
|
||||
@@ -83,11 +83,6 @@ public class ReactiveMongoTemplateTransactionTests {
|
||||
.expectNext(Success.SUCCESS) //
|
||||
.verifyComplete();
|
||||
|
||||
MongoTestUtils.createOrReplaceCollection(DATABASE_NAME, "personWithVersionPropertyOfTypeInteger", client)
|
||||
.as(StepVerifier::create).expectNext(Success.SUCCESS) //
|
||||
.verifyComplete();
|
||||
|
||||
template.insert(DOCUMENT, COLLECTION_NAME).as(StepVerifier::create).expectNextCount(1).verifyComplete();
|
||||
StepVerifier.create(template.insert(DOCUMENT, COLLECTION_NAME)).expectNextCount(1).verifyComplete();
|
||||
|
||||
template.insertAll(Arrays.asList(AHMANN, ARLEN, LEESHA, RENNA)) //
|
||||
|
||||
Reference in New Issue
Block a user