From 6d23f6a64cc07fbb27c869e69bdb3e3757c9904e Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Wed, 16 Jan 2008 01:34:31 +0000
Subject: [PATCH] Exposed setter for messagingTaskScheduler.

---
 .../org/springframework/integration/bus/MessageBus.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java b/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java
index d3a6037232..22c69adcfc 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java
@@ -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.
 	 */