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

PollingSourceAdapter does schedule tasks when connected to a SynchronousChannel (INT-187).

Browse Source
This commit is contained in:
Mark Fisher
2008-04-11 12:18:03 +00:00
parent 64d46f7e67
commit 87e5edb0dc
2 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceAdapterTests.java
View File

@@ -39,6 +39,7 @@ public class ByteStreamSourceAdapterTests {
MessageChannel channel = new SimpleChannel();
ByteStreamSourceAdapter adapter = new ByteStreamSourceAdapter(stream);
adapter.setChannel(channel);
adapter.setInitialDelay(10000);
adapter.start();
int count = adapter.processMessages();
assertEquals(1, count);
@@ -62,6 +63,7 @@ public class ByteStreamSourceAdapterTests {
MessageChannel channel = new SimpleChannel();
ByteStreamSourceAdapter adapter = new ByteStreamSourceAdapter(stream);
adapter.setChannel(channel);
adapter.setInitialDelay(10000);
adapter.setBytesPerMessage(8);
adapter.setMaxMessagesPerTask(5);
adapter.start();

7
spring-integration-core/src/main/java/org/springframework/integration/adapter/PollingSourceAdapter.java
View File

@@ -121,13 +121,6 @@ public class PollingSourceAdapter<T> extends AbstractSourceAdapter<T> implements
if (!this.isInitialized()) {
this.afterPropertiesSet();
}
if (this.getChannel() instanceof SynchronousChannel) {
if (logger.isInfoEnabled()) {
logger.info("source adapter configured on synchronous channel, not scheduling");
}
this.running = true;
return;
}
if (this.scheduler == null) {
if (logger.isInfoEnabled()) {
logger.info("no task scheduler has been provided, will create one");