From 8f1cf63f5ed46cdad8c0113d2ea72ceb218e30fb Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Mon, 14 Jul 2008 22:49:38 +0000
Subject: [PATCH] Added support (in the schema) for the <poller/> sub-element
 within a <channel-adapter/> and added a setSource(MessageSource) method to
 DirectChannel.

---
 .../integration/config/spring-integration-core-1.0.xsd        | 1 +
 .../springframework/integration/dispatcher/DirectChannel.java | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd b/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd
index c29223db61..a7081ef4f4 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd
@@ -180,6 +180,7 @@
 				<xsd:extension base="beans:identifiedType">
 					<xsd:all>
 						<xsd:element ref="schedule" minOccurs="0" maxOccurs="1"/>
+						<xsd:element ref="poller" minOccurs="0" maxOccurs="1"/>
 						<xsd:element name="interceptors" type="interceptorsType" minOccurs="0" maxOccurs="1"/>
 					</xsd:all>
 					<xsd:attribute name="source" type="xsd:string"/>
diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/DirectChannel.java b/org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/DirectChannel.java
index b170558c83..f1118f8a28 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/DirectChannel.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/DirectChannel.java
@@ -56,6 +56,10 @@ public class DirectChannel extends AbstractMessageChannel implements Subscribabl
 	}
 
 
+	public void setSource(MessageSource<?> source) {
+		this.source = source;
+	}
+
 	public boolean subscribe(MessageTarget target) {
 		boolean added = this.dispatcher.addTarget(target);
 		if (added) {