From 598fc0b8e7ea178ea74bcd1448bb03b1b757f402 Mon Sep 17 00:00:00 2001 From: John Carey Date: Fri, 6 Oct 2017 19:42:50 -0400 Subject: [PATCH] Fixing @Transformer for ProcessorApplication. Without explicitly naming the `inputChannel` and `outputChannel`, well get this error on startup org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers --- .../src/main/asciidoc/spring-cloud-stream-overview.adoc | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc index a1d14a4d8..c0d748730 100644 --- a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc +++ b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc @@ -790,6 +790,8 @@ A possible alternative is to provide the source, sink or processor configuration ---- package com.app.mysink; +// Imports omitted + @SpringBootApplication @EnableBinding(Sink.class) public class SinkApplication { @@ -813,7 +815,7 @@ package com.app.myprocessor; @EnableBinding(Processor.class) public class ProcessorApplication { - @Transformer + @Transformer(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT) public String loggerSink(String payload) { return payload.toUpperCase(); }