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) {