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

Adjusted test expectations and receive interval.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-26 21:59:37 +00:00
parent 4a5f737d1d
commit f78cae327d
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -24,6 +24,7 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import org.junit.Test;
import org.springframework.integration.channel.PointToPointChannel;
import org.springframework.integration.endpoint.GenericMessageEndpoint;
import org.springframework.integration.endpoint.MessageEndpoint;
@@ -42,7 +43,7 @@ public class FixedRateConsumerTests {
final CountDownLatch latch = new CountDownLatch(messagesToSend);
PointToPointChannel channel = new PointToPointChannel();
MessageEndpoint endpoint = new GenericMessageEndpoint() {
public void messageReceived(Message message) {
public void messageReceived(Message<?> message) {
counter.incrementAndGet();
latch.countDown();
}
@@ -73,7 +74,7 @@ public class FixedRateConsumerTests {
final CountDownLatch latch = new CountDownLatch(messagesToSend);
PointToPointChannel channel = new PointToPointChannel();
MessageEndpoint endpoint = new GenericMessageEndpoint() {
public void messageReceived(Message message) {
public void messageReceived(Message<?> message) {
counter.incrementAndGet();
latch.countDown();
}
@@ -86,7 +87,7 @@ public class FixedRateConsumerTests {
policy.setMaxConcurrency(1);
policy.setMaxMessagesPerTask(1);
policy.setFixedRate(true);
policy.setPeriod(10);
policy.setPeriod(20);
Subscription subscription = new Subscription();
subscription.setChannel("testChannel");
subscription.setEndpoint("testEndpoint");
@@ -97,8 +98,9 @@ public class FixedRateConsumerTests {
channel.send(new GenericMessage<String>(1, "test " + (i+1)));
}
latch.await(80, TimeUnit.MILLISECONDS);
assertTrue(counter.get() < 10);
assertTrue("only " + counter.get() + " messages received", counter.get() > 7);
int count = counter.get();
assertTrue("received " + count + ", but expected less than 6", count < 6);
assertTrue("received " + count + ", but expected more than 3", count > 3);
}
}