From 984d335f14713aff52d13139b8c85fe2afa00d9e Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Sat, 17 May 2008 18:55:35 +0000 Subject: [PATCH] PollingSourceEndpoint only expects a Schedule instance in its constructor rather than requiring a PollingSchedule instance. --- .../integration/endpoint/PollingSourceEndpoint.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/PollingSourceEndpoint.java b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/PollingSourceEndpoint.java index d268448f5d..f987a62797 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/PollingSourceEndpoint.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/PollingSourceEndpoint.java @@ -31,12 +31,11 @@ import org.springframework.integration.dispatcher.PollingDispatcher; import org.springframework.integration.dispatcher.PollingDispatcherTask; import org.springframework.integration.message.Source; import org.springframework.integration.scheduling.MessagingTask; -import org.springframework.integration.scheduling.PollingSchedule; import org.springframework.integration.scheduling.Schedule; import org.springframework.util.Assert; /** - * A channel adapter that retrieves messages from a {@link PollableSource} + * A channel adapter that retrieves messages from a {@link Source} * and then sends the resulting messages to the provided {@link MessageChannel}. * * @author Mark Fisher @@ -60,7 +59,7 @@ public class PollingSourceEndpoint extends AbstractSourceEndpoint implements Mes private final Object taskMonitor = new Object(); - public PollingSourceEndpoint(Source source, MessageChannel channel, PollingSchedule schedule) { + public PollingSourceEndpoint(Source source, MessageChannel channel, Schedule schedule) { super(source, channel); Assert.notNull(schedule, "schedule must not be null"); this.dispatcher = new DefaultPollingDispatcher(source, this.dispatcherPolicy);