diff --git a/spring-integration-core/src/test/java/org/springframework/integration/dispatcher/PollingTransactionTests.java b/spring-integration-core/src/test/java/org/springframework/integration/dispatcher/PollingTransactionTests.java index 58ead530bf..549ee8a439 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/dispatcher/PollingTransactionTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/dispatcher/PollingTransactionTests.java @@ -93,7 +93,8 @@ public class PollingTransactionTests { input.send(new GenericMessage("test")); txManager.waitForCompletion(10000); Message message = output.receive(0); - assertNotNull(message); + assertNotNull(message); + assertEquals(1, txManager.getCommitCount()); assertEquals(0, txManager.getRollbackCount()); context.stop(); }