Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Test does not need counter.

Browse Source
This commit is contained in:
Mark Fisher
2008-01-16 22:23:29 +00:00
parent 8225cb1405
commit 0d7106b320
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-core/src/test/java/org/springframework/integration/bus/FixedRateConsumerTests.java
View File

@@ -40,12 +40,10 @@ public class FixedRateConsumerTests {
@Test
public void testAllSentMessagesAreReceivedWithinTimeLimit() throws Exception {
int messagesToSend = 20;
final AtomicInteger counter = new AtomicInteger(0);
final CountDownLatch latch = new CountDownLatch(messagesToSend);
SimpleChannel channel = new SimpleChannel();
MessageHandler handler = new MessageHandler() {
public Message<?> handle(Message<?> message) {
counter.incrementAndGet();
latch.countDown();
return null;
}
@@ -63,8 +61,8 @@ public class FixedRateConsumerTests {
for (int i = 0; i < messagesToSend; i++) {
channel.send(new GenericMessage<String>(1, "test " + (i+1)));
}
latch.await(210, TimeUnit.MILLISECONDS);
assertEquals(messagesToSend, counter.get());
latch.await(250, TimeUnit.MILLISECONDS);
assertEquals("all messages should have been received within the time limit", 0, latch.getCount());
}
@Test