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

INT-1758 added test for deprecated usage of setPollerMetadata() on AbstractPollingEndpoint

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-01-21 11:47:49 -05:00
parent dddf29a39d
commit 8cf0c559d6
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java
View File

@@ -41,6 +41,7 @@ import org.springframework.integration.MessageRejectedException;
import org.springframework.integration.core.MessageHandler;
import org.springframework.integration.core.PollableChannel;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.scheduling.PollerMetadata;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
@@ -120,6 +121,23 @@ public class PollingConsumerEndpointTests {
assertEquals(5, consumer.counter.get());
verify(channelMock);
}
@Test
public void multipleMessagesWithPollerMetadata() {
expect(channelMock.receive()).andReturn(message).times(5);
replay(channelMock);
PollerMetadata pollerMetadata = new PollerMetadata();
pollerMetadata.setMaxMessagesPerPoll(5);
pollerMetadata.setTrigger(trigger);
endpoint.setPollerMetadata(pollerMetadata);
endpoint.start();
trigger.await();
endpoint.stop();
assertEquals(5, consumer.counter.get());
verify(channelMock);
}
@Test
public void multipleMessages_underrun() {