From 948e0f7ac75880768c3b1cda4759ff254d2074f6 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 28 Dec 2007 18:57:38 +0000
Subject: [PATCH] Test class did not show up in synchronize view. Should have
 been committed with previous changes.

---
 .../adapter/PollingSourceAdapterTests.java    | 20 +++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/adapter/PollingSourceAdapterTests.java b/spring-integration-core/src/test/java/org/springframework/integration/adapter/PollingSourceAdapterTests.java
index 0e1a18f605..c0a37c98a8 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/adapter/PollingSourceAdapterTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/adapter/PollingSourceAdapterTests.java
@@ -40,7 +40,9 @@ public class PollingSourceAdapterTests {
 	public void testPolledSourceSendsToChannel() {
 		TestSource source = new TestSource("testing", 1);
 		PointToPointChannel channel = new PointToPointChannel();
-		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source, channel, 100);
+		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source);
+		adapter.setChannel(channel);
+		adapter.setPeriod(100);
 		adapter.receiveAndDispatch();
 		Message<?> message = channel.receive();
 		assertNotNull("message should not be null", message);
@@ -51,7 +53,9 @@ public class PollingSourceAdapterTests {
 	public void testSendTimeout() {
 		TestSource source = new TestSource("testing", 1);
 		PointToPointChannel channel = new PointToPointChannel(1);
-		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source, channel, 500);
+		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source);
+		adapter.setChannel(channel);
+		adapter.setPeriod(500);
 		adapter.setSendTimeout(10);
 		adapter.receiveAndDispatch();
 		adapter.receiveAndDispatch();
@@ -70,8 +74,10 @@ public class PollingSourceAdapterTests {
 	public void testMultipleMessagesPerPoll() {
 		TestSource source = new TestSource("testing", 3);
 		PointToPointChannel channel = new PointToPointChannel();
-		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source, channel, 1000);
-		adapter.setLimit(5);
+		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source);
+		adapter.setChannel(channel);
+		adapter.setPeriod(1000);
+		adapter.setMaxMessagesPerTask(5);
 		adapter.receiveAndDispatch();
 		Message<?> message1 = channel.receive(0);
 		assertNotNull("message should not be null", message1);
@@ -90,8 +96,10 @@ public class PollingSourceAdapterTests {
 	public void testResultSizeExceedsLimit() {
 		TestSource source = new TestSource("testing", 3);
 		PointToPointChannel channel = new PointToPointChannel();
-		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source, channel, 1000);
-		adapter.setLimit(2);
+		PollingSourceAdapter<String> adapter = new PollingSourceAdapter<String>(source);
+		adapter.setChannel(channel);
+		adapter.setPeriod(1000);
+		adapter.setMaxMessagesPerTask(2);
 		adapter.receiveAndDispatch();
 	}