bugfix: ephemeral readmodels are now correctly populated upon restart

vanrogu · vanrogu · commit 3cb06dde2c4e · 2026-02-01T15:54:15.000+01:00
diff --git a/sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/eventdispatching/EventuallyConsistentEventProcessor.java b/sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/eventdispatching/EventuallyConsistentEventProcessor.java
@@ -118,7 +118,7 @@ public void run ( ) {
 		
 		if ( processorIdentification.storage() == Storage.EPHEMERAL ) {
 			LOGGER.info("EPHEMERAL storage, processing stream from start ...");
-			mustFetchBookmark = false; // ignore any existing bookmark that might be there from a previous process
+			eventSource.removeBookmark(processorIdentification.toString()); // so we can't read one from a previous run for ephemeral readmodels
 		}
 		
 		while ( instanceMode != ProcessorInstanceMode.TERMINATING ) {

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ public void run ( ) {`
`118`	`118`
`119`	`119`	`if ( processorIdentification.storage() == Storage.EPHEMERAL ) {`
`120`	`120`	`LOGGER.info("EPHEMERAL storage, processing stream from start ...");`
`121`		`- mustFetchBookmark = false; // ignore any existing bookmark that might be there from a previous process`
	`121`	`+ eventSource.removeBookmark(processorIdentification.toString()); // so we can't read one from a previous run for ephemeral readmodels`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`while ( instanceMode != ProcessorInstanceMode.TERMINATING ) {`