From 8ac35f723fbb5bc5acdd735efa266162abd5b296 Mon Sep 17 00:00:00 2001 From: Thomas Vitale Date: Wed, 30 Dec 2020 17:31:18 +0100 Subject: [PATCH] Fix test binder usage examples The examples for testing Spring Cloud Stream in the presence of multiple bindings contain some mistakes that make the tests fail. Resolves #2070 --- docs/src/main/asciidoc/spring-cloud-stream.adoc | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/docs/src/main/asciidoc/spring-cloud-stream.adoc b/docs/src/main/asciidoc/spring-cloud-stream.adoc index 85c358194..2ea75c587 100644 --- a/docs/src/main/asciidoc/spring-cloud-stream.adoc +++ b/docs/src/main/asciidoc/spring-cloud-stream.adoc @@ -2955,12 +2955,12 @@ public void testMultipleFunctions() { Message inputMessage = MessageBuilder.withPayload("Hello".getBytes()).build(); inputDestination.send(inputMessage, "uppercase-in-0"); - inputDestination.send(inputMessage, "uppercase-in-0"); + inputDestination.send(inputMessage, "reverse-in-0"); Message outputMessage = outputDestination.receive(0, "uppercase-out-0"); assertThat(outputMessage.getPayload()).isEqualTo("HELLO".getBytes()); - outputMessage = outputDestination.receive(0, "uppercase-out-0"); + outputMessage = outputDestination.receive(0, "reverse-out-0"); assertThat(outputMessage.getPayload()).isEqualTo("olleH".getBytes()); } } @@ -2978,7 +2978,7 @@ public void testMultipleFunctions() { .run( "--spring.cloud.function.definition=uppercase;reverse", "--spring.cloud.stream.bindings.uppercase-in-0.destination=myInput", - "--spring.cloud.stream.bindings.uppercase-out-0.destination=myOutput", + "--spring.cloud.stream.bindings.uppercase-out-0.destination=myOutput" )) { InputDestination inputDestination = context.getBean(InputDestination.class); @@ -2986,12 +2986,12 @@ public void testMultipleFunctions() { Message inputMessage = MessageBuilder.withPayload("Hello".getBytes()).build(); inputDestination.send(inputMessage, "myInput"); - inputDestination.send(inputMessage, "myInput"); + inputDestination.send(inputMessage, "reverse-in-0"); Message outputMessage = outputDestination.receive(0, "myOutput"); assertThat(outputMessage.getPayload()).isEqualTo("HELLO".getBytes()); - outputMessage = outputDestination.receive(0, "myOutput"); + outputMessage = outputDestination.receive(0, "reverse-out-0"); assertThat(outputMessage.getPayload()).isEqualTo("olleH".getBytes()); } }