diff --git a/spring-integration-jmx/src/test/java/org/springframework/integration/monitor/MessageSourceMonitoringIntegrationTests.java b/spring-integration-jmx/src/test/java/org/springframework/integration/monitor/MessageSourceMonitoringIntegrationTests.java index 446caf2e85..d0d780bb16 100644 --- a/spring-integration-jmx/src/test/java/org/springframework/integration/monitor/MessageSourceMonitoringIntegrationTests.java +++ b/spring-integration-jmx/src/test/java/org/springframework/integration/monitor/MessageSourceMonitoringIntegrationTests.java @@ -55,6 +55,7 @@ public class MessageSourceMonitoringIntegrationTests { int before = service.getCounter(); channel.receive(1000L); + channel.receive(1000L); assertTrue(before < service.getCounter()); int count = exporter.getSourceMessageCount(monitor);