Fix: Change resumeAfter to startAfter.

startAfter seems to be a bug fix for resumeAfter that adds support for INVALIDATE events. Not sure why anyone wouldn't want that.
prdoyle · Jun 14, 2023 · 12d6b0e · 12d6b0e
1 parent 29c6c71
commit 12d6b0e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bosk-mongo/src/main/java/io/vena/bosk/drivers/mongo/v2/ChangeEventReceiver.java b/bosk-mongo/src/main/java/io/vena/bosk/drivers/mongo/v2/ChangeEventReceiver.java
@@ -209,7 +209,7 @@ private boolean setupNewSession(ChangeEventListener newListener) {
 			}
 			try {
 				MongoChangeStreamCursor<ChangeStreamDocument<Document>> cursor
-					= collection.watch().resumeAfter(resumePoint).cursor();
+					= collection.watch().startAfter(resumePoint).cursor();
 				currentSession = new Session(cursor, newListener, initialEvent, false);
 				return true;
 			} catch (MongoCommandException e) {