diff --git a/spring-integration-core/src/test/java/org/springframework/integration/adapter/AdapterTests.java b/spring-integration-core/src/test/java/org/springframework/integration/adapter/AdapterTests.java index a92063b8d3..420986231b 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/adapter/AdapterTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/adapter/AdapterTests.java @@ -42,11 +42,9 @@ public class AdapterTests { sink.setLatch(latch); assertNull(sink.get()); context.start(); - String result = null; latch.await(3000, TimeUnit.MILLISECONDS); assertEquals("latch should have counted down within allotted time", 0, latch.getCount()); - result = sink.get(); - assertNotNull(result); + assertNotNull(sink.get()); context.close(); } @@ -58,11 +56,9 @@ public class AdapterTests { sink.setLatch(latch); assertNull(sink.get()); context.start(); - String result = null; latch.await(3000, TimeUnit.MILLISECONDS); assertEquals("latch should have counted down within allotted time", 0, latch.getCount()); - result = sink.get(); - assertNotNull(result); + assertNotNull(sink.get()); context.close(); } diff --git a/spring-integration-core/src/test/java/org/springframework/integration/adapter/TestSink.java b/spring-integration-core/src/test/java/org/springframework/integration/adapter/TestSink.java index 3836669a3e..c45b6dd6f1 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/adapter/TestSink.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/adapter/TestSink.java @@ -43,10 +43,10 @@ public class TestSink { } public void store(String s) { + this.result = s; if (this.latch != null) { this.latch.countDown(); } - this.result = s; } public String get() {