upgrade to eventstore 0.4.2

Author: vanrogu

pom.xml

@@ -34,7 +34,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-		<sliceworkz.eventstore.version>0.4.1</sliceworkz.eventstore.version>
+		<sliceworkz.eventstore.version>0.4.2</sliceworkz.eventstore.version>
 
 		<maven.minimal-version>3.6.3</maven.minimal-version>
 

sliceworkz-eventmodeling-examples/src/main/java/org/sliceworkz/eventmodeling/examples/banking/BankingExample.java

@@ -77,12 +77,13 @@ public static void main ( String[] args ) {
 					private EventReference lastSeen;
 
 					@Override
-					public void eventsAppended(EventReference atLeastUntil) {
+					public EventReference eventsAppended(EventReference atLeastUntil) {
 						List<Event<BankingDomainEvent>> events = eventStream.query(EventQuery.matchAll(), lastSeen).toList();
 						events.forEach(System.out::println);
 						if ( events.size() > 0 ) {
 							lastSeen = events.getLast().reference();
 						}
+						return lastSeen;
 					}
 				}
 			);

sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/eventdispatching/EventuallyConsistentEventProcessor.java

@@ -92,7 +92,7 @@ public void start ( ) {
 	}
 
 	@Override
-	public void eventsAppended(EventReference atLeastUntil) {
+	public EventReference eventsAppended(EventReference atLeastUntil) {
 		LOGGER.debug("eventually consistent event processor notified of updates until at least {}", atLeastUntil);
 		if ( lastReference == null || (atLeastUntil.position() > lastReference.position()) ) {
 			// might be new interesting events.  in case we're wait()-ing, let's continue and query immediately to check!
@@ -101,9 +101,11 @@ public void eventsAppended(EventReference atLeastUntil) {
 				potentiallyNewEventsAppended = true;
 				this.notify();
 			}
+			return atLeastUntil;
 		} else {
 			// nothing new to discover, we're already at this position in the stream with our processing
 			LOGGER.debug("nothing new to process based on this update, already at {}", lastReference);
+			return lastReference;
 		}
 	}
 

sliceworkz-eventmodeling-tests-inmem/src/test/java/org/sliceworkz/eventmodeling/mock/boundedcontext/InvocationCountingEventStorage.java

@@ -79,5 +79,10 @@ public Optional<EventReference> getBookmark(String reader) {
 	public void bookmark(String reader, EventReference eventReference, Tags tags ) {
 		wrapped.bookmark(reader, eventReference, tags);
 	}
+
+	@Override
+	public void removeBookmark(String reader) {
+		wrapped.removeBookmark(reader);
+	}
 
 }