diff --git a/redis/streams/src/main/java/example/springdata/redis/sync/CapturingStreamListener.java b/redis/streams/src/main/java/example/springdata/redis/sync/CapturingStreamListener.java
index fbd21b25..c29366c9 100644
--- a/redis/streams/src/main/java/example/springdata/redis/sync/CapturingStreamListener.java
+++ b/redis/streams/src/main/java/example/springdata/redis/sync/CapturingStreamListener.java
@@ -24,6 +24,7 @@ import org.springframework.data.redis.stream.StreamListener;
 
 /**
  * @author Christoph Strobl
+ * @author Mark Paluch
  */
 public class CapturingStreamListener implements StreamListener<String, MapRecord<String, String, String>> {
 
@@ -36,8 +37,8 @@ public class CapturingStreamListener implements StreamListener<String, MapRecord
 	@Override
 	public void onMessage(MapRecord<String, String, String> record) {
 
-		deque.add(record);
 		counter.incrementAndGet();
+		deque.add(record);
 	}
 
 	/**