diff --git a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/repeat/jms/AsynchronousTests.java b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/repeat/jms/AsynchronousTests.java index 5e6c49296..9ddcda0a8 100644 --- a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/repeat/jms/AsynchronousTests.java +++ b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/repeat/jms/AsynchronousTests.java @@ -163,6 +163,8 @@ public class AsynchronousTests { // message... Thread.sleep(1000L); + container.stop(); + // We rolled back so the messages might come in many times... assertTrue(list.size() >= 1);