diff --git a/message-channel/pom.xml b/message-channel/pom.xml
index a8a7f4ee2..ce29ac9fd 100644
--- a/message-channel/pom.xml
+++ b/message-channel/pom.xml
@@ -14,6 +14,10 @@
 			<groupId>org.apache.camel</groupId>
 			<artifactId>camel-core</artifactId>
 		</dependency>
+			<dependency>
+				<groupId>org.apache.camel</groupId>
+				<artifactId>camel-stream</artifactId>
+			</dependency>
 		<dependency>
 			<groupId>junit</groupId>
 			<artifactId>junit</artifactId>
diff --git a/message-channel/src/main/java/com/iluwatar/message/channel/App.java b/message-channel/src/main/java/com/iluwatar/message/channel/App.java
index 9e8c4ba85..64201fdfb 100644
--- a/message-channel/src/main/java/com/iluwatar/message/channel/App.java
+++ b/message-channel/src/main/java/com/iluwatar/message/channel/App.java
@@ -1,14 +1,27 @@
 package com.iluwatar.message.channel;
 
 import org.apache.camel.CamelContext;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.DefaultCamelContext;
 
 public class App {
 	
 	public static void main(String[] args) throws Exception {
 		CamelContext context = new DefaultCamelContext();
+		
+		context.addRoutes(new RouteBuilder() {
+
+			@Override
+			public void configure() throws Exception {
+				from("direct:greetings").to("stream:out");
+			}
+		});
+		
 		context.start();
-		Thread.sleep(10000);
+		ProducerTemplate template = context.createProducerTemplate();
+		template.sendBody("direct:greetings", "jou man");
+		Thread.sleep(1000);
 		context.stop();
 	}
 }
diff --git a/pom.xml b/pom.xml
index 7300c5f00..391ddd9c1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -111,6 +111,11 @@
 				<artifactId>camel-core</artifactId>
 				<version>${camel.version}</version>
 			</dependency>
+			<dependency>
+				<groupId>org.apache.camel</groupId>
+				<artifactId>camel-stream</artifactId>
+				<version>${camel.version}</version>
+			</dependency>
 			<dependency>
 				<groupId>junit</groupId>
 				<artifactId>junit</artifactId>