diff --git a/pom.xml b/pom.xml
index 37447d50b0f8d4667660c1ac3d14433ac0991faf..c3b6bcdf687d9a9674e06923c42b74138c276803 100644
--- a/pom.xml
+++ b/pom.xml
@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>beamline</groupId>
 	<artifactId>framework</artifactId>
-	<version>0.2.2</version>
+	<version>0.2.3</version>
 
 	<properties>
 		<maven.compiler.source>11</maven.compiler.source>
diff --git a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
index f1d71096d4ad06b7fc6ae7d96750e95513936624..9e016b5f9954e78fded448c457d38ed4c8d3cc85 100644
--- a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
+++ b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
@@ -81,9 +81,11 @@ public abstract class StreamMiningAlgorithm<T extends Response> extends RichFlat
 	 */
 	protected T process(BEvent event) {
 		try {
-			long value = 1;
-			if (processedEvents != null && processedEvents.value() != null) {
-				value = processedEvents.value() + 1;
+			long value = 0;
+			if (processedEvents != null) {
+				if (processedEvents.value() != null) {
+					value = processedEvents.value() + 1;
+				}
 				processedEvents.update(value);
 			}
 		} catch (IOException e) {