diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/config/spring-integration-adapters-1.0.xsd b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/config/spring-integration-adapters-1.0.xsd
index 9cb7fdaf70..61c714c11b 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/config/spring-integration-adapters-1.0.xsd
+++ b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/config/spring-integration-adapters-1.0.xsd
@@ -255,35 +255,6 @@
 		</xsd:complexType>
 	</xsd:element>
 
-	<xsd:element name="console-source">
-		<xsd:complexType>
-			<xsd:annotation>
-				<xsd:documentation>
-	Configures a source that reads from stdin (System.in).
-				</xsd:documentation>
-			</xsd:annotation>
-			<xsd:attribute name="id" type="xsd:string"/>
-			<xsd:attribute name="charset" type="xsd:string"/>
-		</xsd:complexType>
-	</xsd:element>
-
-	<xsd:element name="stdout-channel-adapter" type="consoleOutboundChannelAdapterType"/>
-
-	<xsd:element name="stderr-channel-adapter" type="consoleOutboundChannelAdapterType"/>
-
-	<xsd:complexType name="consoleOutboundChannelAdapterType">
-		<xsd:annotation>
-			<xsd:documentation>
-	Configures an outbound Channel Adapter that writes to stdout (System.out)
-	or to stderr (System.err) depending on the element name.
-			</xsd:documentation>
-		</xsd:annotation>
-		<xsd:attribute name="id" type="xsd:string"/>
-		<xsd:attribute name="channel" type="xsd:string"/>
-		<xsd:attribute name="charset" type="xsd:string"/>
-		<xsd:attribute name="append-newline" type="xsd:boolean" default="false"/>
-	</xsd:complexType>
-
 	<xsd:complexType name="gatewayType">
 		<xsd:annotation>
 			<xsd:documentation>
diff --git a/org.springframework.integration.adapter/src/main/resources/META-INF/spring-integration.parsers b/org.springframework.integration.adapter/src/main/resources/META-INF/spring-integration.parsers
index 9342b0b362..739e597bd2 100644
--- a/org.springframework.integration.adapter/src/main/resources/META-INF/spring-integration.parsers
+++ b/org.springframework.integration.adapter/src/main/resources/META-INF/spring-integration.parsers
@@ -1,4 +1,3 @@
-console-source=org.springframework.integration.adapter.stream.config.ConsoleSourceParser
 file-source=org.springframework.integration.adapter.file.config.FileSourceParser
 file-target=org.springframework.integration.adapter.file.config.FileTargetParser
 ftp-source=org.springframework.integration.adapter.ftp.config.FtpSourceParser
@@ -11,6 +10,4 @@ mail-target=org.springframework.integration.adapter.mail.config.MailTargetParser
 polling-mail-source=org.springframework.integration.adapter.mail.config.PollingMailSourceParser
 imap-idle-mail-source=org.springframework.integration.adapter.mail.config.SubscribableImapIdleMailSourceParser
 rmi-gateway=org.springframework.integration.adapter.rmi.config.RmiGatewayParser
-rmi-handler=org.springframework.integration.adapter.rmi.config.RmiHandlerParser
-stderr-channel-adapter=org.springframework.integration.adapter.stream.config.ConsoleTargetParser
-stdout-channel-adapter=org.springframework.integration.adapter.stream.config.ConsoleTargetParser
\ No newline at end of file
+rmi-handler=org.springframework.integration.adapter.rmi.config.RmiHandlerParser
\ No newline at end of file
diff --git a/org.springframework.integration.samples/.classpath b/org.springframework.integration.samples/.classpath
index 25acd2f2f9..7fbf8a7d0c 100644
--- a/org.springframework.integration.samples/.classpath
+++ b/org.springframework.integration.samples/.classpath
@@ -19,5 +19,6 @@
 	<classpathentry combineaccessrules="false" kind="src" path="/org.springframework.integration.adapter"/>
 	<classpathentry combineaccessrules="false" kind="src" path="/org.springframework.integration.ws"/>
 	<classpathentry combineaccessrules="false" kind="src" path="/org.springframework.integration.quartz"/>
+	<classpathentry combineaccessrules="false" kind="src" path="/org.springframework.integration.stream"/>
 	<classpathentry kind="output" path="target/classes"/>
 </classpath>
diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/cafeDemo.xml b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/cafeDemo.xml
index a5e4873b21..492a389ee4 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/cafeDemo.xml
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/cafeDemo.xml
@@ -3,12 +3,15 @@
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xmlns:beans="http://www.springframework.org/schema/beans"
 	xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans
 			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+			http://www.springframework.org/schema/context
+			http://www.springframework.org/schema/context/spring-context-2.5.xsd
 			http://www.springframework.org/schema/integration
 			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
-			http://www.springframework.org/schema/context
-			http://www.springframework.org/schema/context/spring-context-2.5.xsd">
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
 
 	<message-bus/>
 	<annotation-driven/>
@@ -30,6 +33,6 @@
 
     <channel id="preparedDrinks"/>
 
-	<stdout-channel-adapter id="deliveries"/>
+	<stream:stdout-channel-adapter id="deliveries"/>
 	
 </beans:beans>
diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/xml/cafeDemo.xml b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/xml/cafeDemo.xml
index a45abac939..f8f7885485 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/xml/cafeDemo.xml
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/xml/cafeDemo.xml
@@ -2,11 +2,13 @@
 <beans:beans xmlns="http://www.springframework.org/schema/integration"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xmlns:beans="http://www.springframework.org/schema/beans"
-	xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans
 			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
 			http://www.springframework.org/schema/integration
-			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
+			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
 
 	<message-bus/>
 
@@ -31,7 +33,7 @@
     <channel id="preparedDrinks"/>
     <aggregator input-channel="preparedDrinks" ref="waiter" method="prepareDelivery" output-channel="deliveries"/>
 
-	<stdout-channel-adapter id="deliveries"/>
+	<stream:stdout-channel-adapter id="deliveries"/>
 
 	<beans:bean id="orderSplitter" class="org.springframework.integration.samples.cafe.xml.OrderSplitter"/>
 
diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/quoteDemo.xml b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/quoteDemo.xml
index a54ab05221..0232714575 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/quoteDemo.xml
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/quoteDemo.xml
@@ -2,10 +2,13 @@
 <beans:beans xmlns="http://www.springframework.org/schema/integration"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans
 			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
 			http://www.springframework.org/schema/integration
-			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
+			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
 
 	<message-bus/>
 
@@ -15,6 +18,6 @@
 
 	<beans:bean class="org.springframework.integration.samples.quote.QuoteService"/>
 
-	<stdout-channel-adapter id="quotes" append-newline="true"/>
+	<stream:stdout-channel-adapter id="quotes" append-newline="true"/>
 
 </beans:beans>
diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/ws/temperatureConversion.xml b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/ws/temperatureConversion.xml
index 4c068991ee..883a77382d 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/ws/temperatureConversion.xml
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/ws/temperatureConversion.xml
@@ -2,10 +2,13 @@
 <beans:beans xmlns="http://www.springframework.org/schema/integration"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans
 			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
 			http://www.springframework.org/schema/integration
-			http://www.springframework.org/schema/integration/spring-integration-ws-1.0.xsd">
+			http://www.springframework.org/schema/integration/spring-integration-ws-1.0.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
 
 	<message-bus/>
 
@@ -19,6 +22,6 @@
 				          uri="http://www.w3schools.com/webservices/tempconvert.asmx"/>
 
 	<!-- The response from the service is logged to the console. -->
-	<stdout-channel-adapter id="celsiusChannel"/>
+	<stream:stdout-channel-adapter id="celsiusChannel"/>
 
 </beans:beans>
diff --git a/org.springframework.integration.stream/.classpath b/org.springframework.integration.stream/.classpath
new file mode 100644
index 0000000000..1edf4aed5a
--- /dev/null
+++ b/org.springframework.integration.stream/.classpath
@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src/main/java"/>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java"/>
+	<classpathentry kind="src" path="src/main/resources"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+	<classpathentry kind="var" path="IVY_CACHE/org.apache.commons/com.springsource.org.apache.commons.logging/1.1.1/com.springsource.org.apache.commons.logging-1.1.1.jar" sourcepath="/IVY_CACHE/org.apache.commons/com.springsource.org.apache.commons.logging/1.1.1/com.springsource.org.apache.commons.logging-sources-1.1.1.jar"/>
+	<classpathentry kind="var" path="IVY_CACHE/org.junit/com.springsource.org.junit/4.4.0/com.springsource.org.junit-4.4.0.jar" sourcepath="/IVY_CACHE/org.junit/com.springsource.org.junit/4.4.0/com.springsource.org.junit-sources-4.4.0.jar"/>
+	<classpathentry kind="var" path="IVY_CACHE/org.springframework/org.springframework.beans/2.5.5.A/org.springframework.beans-2.5.5.A.jar" sourcepath="/IVY_CACHE/org.springframework/org.springframework.beans/2.5.5.A/org.springframework.beans-sources-2.5.5.A.jar"/>
+	<classpathentry kind="var" path="IVY_CACHE/org.springframework/org.springframework.context/2.5.5.A/org.springframework.context-2.5.5.A.jar" sourcepath="/IVY_CACHE/org.springframework/org.springframework.context/2.5.5.A/org.springframework.context-sources-2.5.5.A.jar"/>
+	<classpathentry kind="var" path="IVY_CACHE/org.springframework/org.springframework.core/2.5.5.A/org.springframework.core-2.5.5.A.jar" sourcepath="/IVY_CACHE/org.springframework/org.springframework.core/2.5.5.A/org.springframework.core-sources-2.5.5.A.jar"/>
+	<classpathentry combineaccessrules="false" kind="src" path="/org.springframework.integration"/>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamSource.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamSource.java
similarity index 97%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamSource.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamSource.java
index 6010667bfb..b60b47c983 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamSource.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamSource.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamTarget.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamTarget.java
similarity index 97%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamTarget.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamTarget.java
index 641c693a8c..dec6ddd91e 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/ByteStreamTarget.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamTarget.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import java.io.BufferedOutputStream;
 import java.io.IOException;
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamSource.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamSource.java
similarity index 97%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamSource.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamSource.java
index a87dd1c6cf..4172888e11 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamSource.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamSource.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import java.io.BufferedReader;
 import java.io.IOException;
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamTarget.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamTarget.java
similarity index 98%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamTarget.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamTarget.java
index a5584c301c..ea7c66ce83 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamTarget.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamTarget.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import java.io.BufferedWriter;
 import java.io.IOException;
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParser.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleSourceParser.java
similarity index 56%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParser.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleSourceParser.java
index d238076b76..4d00f4e2db 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParser.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleSourceParser.java
@@ -14,44 +14,33 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream.config;
+package org.springframework.integration.stream.config;
 
 import org.w3c.dom.Element;
 
 import org.springframework.beans.factory.support.BeanDefinitionBuilder;
-import org.springframework.beans.factory.xml.AbstractSingleBeanDefinitionParser;
-import org.springframework.integration.adapter.stream.CharacterStreamSource;
+import org.springframework.beans.factory.support.BeanDefinitionReaderUtils;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.integration.config.AbstractInboundChannelAdapterParser;
+import org.springframework.integration.stream.CharacterStreamSource;
 import org.springframework.util.StringUtils;
 
 /**
- * Parser for the &lt;console-source&gt; element.
+ * Parser for the &lt;stdin-channel-adapter&gt; element.
  * 
  * @author Mark Fisher
  */
-public class ConsoleSourceParser extends AbstractSingleBeanDefinitionParser {
+public class ConsoleSourceParser extends AbstractInboundChannelAdapterParser {
 
 	@Override
-	protected Class<?> getBeanClass(Element element) {
-		return CharacterStreamSource.class;
-	}
-
-	@Override
-	protected boolean shouldGenerateId() {
-		return false;
-	}
-
-	@Override
-	protected boolean shouldGenerateIdAsFallback() {
-		return true;
-	}
-
-	@Override
-	protected void doParse(Element element, BeanDefinitionBuilder builder) {
+	protected String parseSource(Element element, ParserContext parserContext) {
+		BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(CharacterStreamSource.class);
 		builder.setFactoryMethod("stdin");
 		String charsetName = element.getAttribute("charset");
 		if (StringUtils.hasText(charsetName)) {
 			builder.addConstructorArgValue(charsetName);
 		}
+		return BeanDefinitionReaderUtils.registerWithGeneratedName(builder.getBeanDefinition(), parserContext.getRegistry());
 	}
 
 }
diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParser.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleTargetParser.java
similarity index 96%
rename from org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParser.java
rename to org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleTargetParser.java
index 464e63af73..2a258154d7 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParser.java
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/ConsoleTargetParser.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream.config;
+package org.springframework.integration.stream.config;
 
 import org.w3c.dom.Element;
 
@@ -26,8 +26,8 @@ import org.springframework.beans.factory.support.BeanDefinitionReaderUtils;
 import org.springframework.beans.factory.xml.AbstractSingleBeanDefinitionParser;
 import org.springframework.beans.factory.xml.ParserContext;
 import org.springframework.integration.ConfigurationException;
-import org.springframework.integration.adapter.stream.CharacterStreamTarget;
 import org.springframework.integration.channel.DirectChannel;
+import org.springframework.integration.stream.CharacterStreamTarget;
 import org.springframework.util.StringUtils;
 
 /**
diff --git a/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/StreamNamespaceHandler.java b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/StreamNamespaceHandler.java
new file mode 100644
index 0000000000..1ba118de66
--- /dev/null
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/StreamNamespaceHandler.java
@@ -0,0 +1,32 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.stream.config;
+
+import org.springframework.beans.factory.xml.NamespaceHandlerSupport;
+
+/**
+ * @author Mark Fisher
+ */
+public class StreamNamespaceHandler extends NamespaceHandlerSupport {
+
+	public void init() {
+		this.registerBeanDefinitionParser("stdin-channel-adapter", new ConsoleSourceParser());
+		this.registerBeanDefinitionParser("stdout-channel-adapter", new ConsoleTargetParser());
+		this.registerBeanDefinitionParser("stderr-channel-adapter", new ConsoleTargetParser());
+	}
+
+}
diff --git a/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/spring-integration-stream-1.0.xsd b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/spring-integration-stream-1.0.xsd
new file mode 100644
index 0000000000..3df04bf6ed
--- /dev/null
+++ b/org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/config/spring-integration-stream-1.0.xsd
@@ -0,0 +1,53 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<xsd:schema xmlns="http://www.springframework.org/schema/integration/stream"
+		xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+		xmlns:beans="http://www.springframework.org/schema/beans"
+		xmlns:tool="http://www.springframework.org/schema/tool"
+		xmlns:integration="http://www.springframework.org/schema/integration"
+		targetNamespace="http://www.springframework.org/schema/integration/stream"
+		elementFormDefault="qualified"
+		attributeFormDefault="unqualified">
+
+	<xsd:import namespace="http://www.springframework.org/schema/beans"/>
+	<xsd:import namespace="http://www.springframework.org/schema/tool"/>
+	<xsd:import namespace="http://www.springframework.org/schema/integration"/>
+
+	<xsd:annotation>
+		<xsd:documentation><![CDATA[
+	Defines the configuration elements for Spring Integration Stream-based Channel Adapters.
+		]]></xsd:documentation>
+	</xsd:annotation>
+
+	<xsd:element name="stdin-channel-adapter">
+		<xsd:annotation>
+			<xsd:documentation>
+	Configures a source that reads from stdin (System.in).
+			</xsd:documentation>
+		</xsd:annotation>
+		<xsd:complexType>
+			<xsd:sequence>
+				<xsd:element ref="integration:poller" minOccurs="0" maxOccurs="1"/>
+			</xsd:sequence>
+			<xsd:attribute name="id" type="xsd:string"/>
+			<xsd:attribute name="charset" type="xsd:string"/>
+		</xsd:complexType>
+	</xsd:element>
+
+	<xsd:element name="stdout-channel-adapter" type="consoleOutboundChannelAdapterType"/>
+
+	<xsd:element name="stderr-channel-adapter" type="consoleOutboundChannelAdapterType"/>
+
+	<xsd:complexType name="consoleOutboundChannelAdapterType">
+		<xsd:annotation>
+			<xsd:documentation>
+	Configures an outbound Channel Adapter that writes to stdout (System.out)
+	or to stderr (System.err) depending on the element name.
+			</xsd:documentation>
+		</xsd:annotation>
+		<xsd:attribute name="id" type="xsd:string"/>
+		<xsd:attribute name="channel" type="xsd:string"/>
+		<xsd:attribute name="charset" type="xsd:string"/>
+		<xsd:attribute name="append-newline" type="xsd:boolean" default="false"/>
+	</xsd:complexType>
+
+</xsd:schema>
diff --git a/org.springframework.integration.stream/src/main/resources/META-INF/spring.handlers b/org.springframework.integration.stream/src/main/resources/META-INF/spring.handlers
new file mode 100644
index 0000000000..2deecf9483
--- /dev/null
+++ b/org.springframework.integration.stream/src/main/resources/META-INF/spring.handlers
@@ -0,0 +1 @@
+http\://www.springframework.org/schema/integration/stream=org.springframework.integration.stream.config.StreamNamespaceHandler
\ No newline at end of file
diff --git a/org.springframework.integration.stream/src/main/resources/META-INF/spring.schemas b/org.springframework.integration.stream/src/main/resources/META-INF/spring.schemas
new file mode 100644
index 0000000000..f9ff2d3535
--- /dev/null
+++ b/org.springframework.integration.stream/src/main/resources/META-INF/spring.schemas
@@ -0,0 +1 @@
+http\://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd=org/springframework/integration/stream/config/spring-integration-stream-1.0.xsd
\ No newline at end of file
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamSourceTests.java
similarity index 97%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamSourceTests.java
index 6ea0b34d0b..f59b543c00 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamSourceTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamTargetTests.java
similarity index 99%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamTargetTests.java
index cb26328b24..a45dc22375 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamTargetTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import static org.junit.Assert.assertEquals;
 
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamSourceTests.java
similarity index 95%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamSourceTests.java
index 4288df0530..8dec3f35d1 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamSourceTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamTargetTests.java
similarity index 98%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamTargetTests.java
index 5199618ac0..1c575704ce 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/CharacterStreamTargetTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream;
+package org.springframework.integration.stream;
 
 import static org.junit.Assert.assertEquals;
 
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParserTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleSourceParserTests.java
similarity index 96%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParserTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleSourceParserTests.java
index 1cd860198c..fcd7365be4 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleSourceParserTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleSourceParserTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream.config;
+package org.springframework.integration.stream.config;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNotNull;
@@ -33,8 +33,8 @@ import org.springframework.beans.DirectFieldAccessor;
 import org.springframework.beans.factory.BeanCreationException;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.integration.ConfigurationException;
-import org.springframework.integration.adapter.stream.CharacterStreamSource;
 import org.springframework.integration.message.Message;
+import org.springframework.integration.stream.CharacterStreamSource;
 
 /**
  * @author Mark Fisher
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParserTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleTargetParserTests.java
similarity index 97%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParserTests.java
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleTargetParserTests.java
index 67caf3843e..a554f9d310 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/ConsoleTargetParserTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/ConsoleTargetParserTests.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.adapter.stream.config;
+package org.springframework.integration.stream.config;
 
 import static org.junit.Assert.assertEquals;
 
@@ -33,8 +33,8 @@ import org.springframework.beans.DirectFieldAccessor;
 import org.springframework.beans.factory.BeanCreationException;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.integration.ConfigurationException;
-import org.springframework.integration.adapter.stream.CharacterStreamTarget;
 import org.springframework.integration.message.StringMessage;
+import org.springframework.integration.stream.CharacterStreamTarget;
 
 /**
  * @author Mark Fisher
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/consoleSourceParserTests.xml b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/consoleSourceParserTests.xml
similarity index 79%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/consoleSourceParserTests.xml
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/consoleSourceParserTests.xml
index ed35e5b1c6..3476b22d84 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/consoleSourceParserTests.xml
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/consoleSourceParserTests.xml
@@ -7,8 +7,8 @@
 			http://www.springframework.org/schema/integration
 			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
 
-	<console-source id="sourceWithDefaultCharset"/>
+	<stdin-channel-adapter id="sourceWithDefaultCharset"/>
 
-	<console-source id="sourceWithProvidedCharset" charset="UTF-8"/>
+	<stdin-channel-adapter id="sourceWithProvidedCharset" charset="UTF-8"/>
 
 </beans:beans>
\ No newline at end of file
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/consoleTargetParserTests.xml b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/consoleTargetParserTests.xml
similarity index 100%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/consoleTargetParserTests.xml
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/consoleTargetParserTests.xml
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/invalidConsoleSourceParserTests.xml b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/invalidConsoleSourceParserTests.xml
similarity index 85%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/invalidConsoleSourceParserTests.xml
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/invalidConsoleSourceParserTests.xml
index d9fe407319..bff6fac9d7 100644
--- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/invalidConsoleSourceParserTests.xml
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/invalidConsoleSourceParserTests.xml
@@ -7,6 +7,6 @@
 			http://www.springframework.org/schema/integration
 			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
 
-	<console-source id="sourceWithInvalidCharset" charset="invalid-charset-name"/>
+	<stdin-channel-adapter id="sourceWithInvalidCharset" charset="invalid-charset-name"/>
 
 </beans:beans>
\ No newline at end of file
diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/invalidConsoleTargetParserTests.xml b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/invalidConsoleTargetParserTests.xml
similarity index 100%
rename from org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/config/invalidConsoleTargetParserTests.xml
rename to org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/config/invalidConsoleTargetParserTests.xml