diff --git a/double/src/main/java/config/processor/ProcessorModuleDefinition.java b/double/src/main/java/config/processor/ProcessorModuleDefinition.java
index 2cc01e1..66227b5 100644
--- a/double/src/main/java/config/processor/ProcessorModuleDefinition.java
+++ b/double/src/main/java/config/processor/ProcessorModuleDefinition.java
@@ -27,7 +27,7 @@ import org.springframework.messaging.Message;
 @EnableBinding(Processor.class)
 public class ProcessorModuleDefinition {
 
-	@Transformer
+	@Transformer(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
 	public Message<?> transform(Message<?> inbound) {
 		return inbound;
 	}
diff --git a/double/src/main/java/demo/DoubleApplication.java b/double/src/main/java/demo/DoubleApplication.java
index 2618445..4e1e458 100644
--- a/double/src/main/java/demo/DoubleApplication.java
+++ b/double/src/main/java/demo/DoubleApplication.java
@@ -16,6 +16,7 @@
 
 package demo;
 
+import config.processor.ProcessorApplication;
 import config.sink.SinkApplication;
 import config.source.SourceApplication;
 
@@ -30,7 +31,7 @@ public class DoubleApplication {
 	public static void main(String[] args) {
 		new AggregateApplicationBuilder().
 				from(SourceApplication.class).args("--fixedDelay=5000")
-				.via(Processor.class)
+				.via(ProcessorApplication.class)
 				.to(SinkApplication.class).args("--debug=true").run("--spring.application.name=aggregate-test");
 	}