GH-2501: Fix Race in Test

garyrussell · garyrussell · commit bdada69d6739 · 2022-12-07T16:16:32.000-05:00
diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
@@ -2210,8 +2210,8 @@ public void validatedListener(@Payload @Valid ValidatedClass val) {
 		public void projectionListener(ProjectionSample sample) {
 			this.username = sample.getUsername();
 			this.name = sample.getName();
-			this.projectionLatch.countDown();
 			this.customThreadName = Thread.currentThread().getName();
+			this.projectionLatch.countDown();
 		}
 
 		@KafkaListener(id = "customMethodArgumentResolver", topics = "annotated39")

Original file line number	Diff line number	Diff line change
`@@ -2210,8 +2210,8 @@ public void validatedListener(@Payload @Valid ValidatedClass val) {`
`2210`	`2210`	`public void projectionListener(ProjectionSample sample) {`
`2211`	`2211`	`this.username = sample.getUsername();`
`2212`	`2212`	`this.name = sample.getName();`
`2213`		`- this.projectionLatch.countDown();`
`2214`	`2213`	`this.customThreadName = Thread.currentThread().getName();`
	`2214`	`+ this.projectionLatch.countDown();`
`2215`	`2215`	`}`
`2216`	`2216`
`2217`	`2217`	`@KafkaListener(id = "customMethodArgumentResolver", topics = "annotated39")`