Update sample to use aggregate-app-builder

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>

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");
 	}
 
 }