From 8038eb7cad8890766c35de11d4898fee52bb5644 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Mon, 11 Nov 2019 15:44:36 +0100
Subject: [PATCH] #542 - Polishing.

Increment received count before adding result to queue to allow for improved synchronization.
---
 .../example/springdata/redis/sync/CapturingStreamListener.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);
 	}
 
 	/**