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

polished PollingLifecycleTests making it more reliable

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-05-03 18:57:13 -04:00
parent c6fad52082
commit 842af05441
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingLifecycleTests.java
View File

@@ -126,14 +126,12 @@ public class PollingLifecycleTests {
pollerMetadata.setMaxMessagesPerPoll(-1);
pollerMetadata.setTrigger(new PeriodicTrigger(2000));
adapterFactory.setPollerMetadata(pollerMetadata);
final Runnable runnable = mock(Runnable.class);
final Runnable coughtInterrupted = mock(Runnable.class);
MessageSource<String> source = new MessageSource<String>() {
public Message<String> receive() {
try {
for (int i = 0; i < 10; i++) {
runnable.run();
for (int i = 0; i < 10; i++) {
Thread.sleep(1000);
latch.countDown();
}
@@ -154,6 +152,7 @@ public class PollingLifecycleTests {
assertTrue(latch.await(3000, TimeUnit.SECONDS));
//
adapter.stop();
Thread.sleep(1000);
Mockito.verify(coughtInterrupted, times(1)).run();
}
}