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

Test class did not show up in synchronize view. Should have been committed with previous changes.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-28 18:57:38 +00:00
parent 6906219773
commit 948e0f7ac7
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-integration-core/src/test/java/org/springframework/integration/adapter/PollingSourceAdapterTests.java
View File

@@ -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();
}