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

Exposed setter for messagingTaskScheduler.

Browse Source
This commit is contained in:
Mark Fisher
2008-01-16 01:34:31 +00:00
parent cc2bd24b8a
commit 6d23f6a64c
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java
View File

@@ -92,6 +92,14 @@ public class MessageBus implements ChannelRegistry, ApplicationContextAware, Lif
this.registerSourceAdapters(applicationContext);
}
public void setMessagingTaskScheduler(MessagingTaskScheduler taskScheduler) {
Assert.notNull(taskScheduler, "task scheduler must not be null");
if (taskScheduler instanceof SimpleMessagingTaskScheduler) {
((SimpleMessagingTaskScheduler) this.taskScheduler).setCorePoolSize(dispatcherPoolSize);
}
this.taskScheduler = taskScheduler;
}
/**
* Set the size for the dispatcher thread pool.
*/