From 8cf0c559d62f94c3693f72c605686ce473f1f262 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Fri, 21 Jan 2011 11:47:49 -0500 Subject: [PATCH] INT-1758 added test for deprecated usage of setPollerMetadata() on AbstractPollingEndpoint --- .../endpoint/PollingConsumerEndpointTests.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java index 2effb58eaa..91f4d778ce 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java @@ -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() {