From acd7070831997a37e7cda3e19040a22ffa00b751 Mon Sep 17 00:00:00 2001
From: Ilkka Seppala <iluwatar@gmail.com>
Date: Sat, 22 Aug 2015 16:37:19 +0300
Subject: [PATCH] #143 Work on the example code

---
 message-channel/pom.xml                           |  4 ++++
 .../java/com/iluwatar/message/channel/App.java    | 15 ++++++++++++++-
 pom.xml                                           |  5 +++++
 3 files changed, 23 insertions(+), 1 deletion(-)

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>