diff --git a/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedRateConsumerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedRateConsumerTests.java index 606951e93a..326f89c594 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedRateConsumerTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedRateConsumerTests.java @@ -39,7 +39,7 @@ public class FixedRateConsumerTests { @Test public void temp() {} - //@Test + @Test public void testAllSentMessagesAreReceivedWithinTimeLimit() throws Exception { int messagesToSend = 20; final AtomicInteger counter = new AtomicInteger(0); @@ -70,7 +70,7 @@ public class FixedRateConsumerTests { assertEquals(messagesToSend, counter.get()); } - //@Test + @Test public void testTimedOutMessagesAreNotReceived() throws Exception { int messagesToSend = 20; final AtomicInteger counter = new AtomicInteger(0);