From f1653abf0960b223ee0fc150e32ddee393b96776 Mon Sep 17 00:00:00 2001
From: Ilayaperumal Gopinathan <igopinathan@pivotal.io>
Date: Mon, 22 Feb 2016 18:24:04 +0530
Subject: [PATCH] Update sample to use aggregate-app-builder

---
 double/pom.xml                                   | 13 +++++--------
 double/src/main/java/demo/DoubleApplication.java |  6 ++++--
 2 files changed, 9 insertions(+), 10 deletions(-)

diff --git a/double/pom.xml b/double/pom.xml
index 9a658f2..0555a47 100644
--- a/double/pom.xml
+++ b/double/pom.xml
@@ -23,14 +23,6 @@
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-stream</artifactId>
 		</dependency>
-		<dependency>
-			<groupId>org.springframework.cloud</groupId>
-			<artifactId>spring-cloud-stream-binder-redis</artifactId>
-		</dependency>
-		<dependency>
-			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-redis</artifactId>
-		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-configuration-processor</artifactId>
@@ -42,6 +34,11 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-stream-binder-redis</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>
diff --git a/double/src/main/java/demo/DoubleApplication.java b/double/src/main/java/demo/DoubleApplication.java
index 3ebe00b..b82d1f2 100644
--- a/double/src/main/java/demo/DoubleApplication.java
+++ b/double/src/main/java/demo/DoubleApplication.java
@@ -17,7 +17,7 @@
 package demo;
 
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.stream.aggregate.AggregateApplication;
+import org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder;
 
 import config.sink.SinkApplication;
 import config.source.SourceApplication;
@@ -26,7 +26,9 @@ import config.source.SourceApplication;
 public class DoubleApplication {
 
 	public static void main(String[] args) {
-		AggregateApplication.run(SourceApplication.class, SinkApplication.class);
+		new AggregateApplicationBuilder().
+				from(SourceApplication.class).args("--fixedDelay=5000")
+				.to(SinkApplication.class).args("--debug=true").run("--spring.application.name=aggregate-test");
 	}
 
 }