SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1894 Added test to demonstrate testing with explicit bindings

Browse Source 
Resolves #1894
This commit is contained in:
Oleg Zhurakousky
2020-01-27 17:56:42 +01:00
parent 67b36959fd
commit 41ab7abc51
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
View File

@@ -443,6 +443,33 @@ public class ImplicitFunctionBindingTests {
}
}
@Test
public void testWithExplicitBindingInstructions() {
System.clearProperty("spring.cloud.function.definition");
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration
.getCompleteConfiguration(SplittableTypesConfiguration.class))
.web(WebApplicationType.NONE).run("--spring.cloud.function.definition=funcArrayOfMessages",
"--spring.cloud.stream.function.bindings.funcArrayOfMessages-in-0=input",
"--spring.cloud.stream.function.bindings.funcArrayOfMessages-out-0=output",
"--spring.cloud.stream.bindings.input.destination=myInput",
"--spring.cloud.stream.bindings.output.destination=myOutput",
"--spring.jmx.enabled=false")) {
InputDestination inputDestination = context.getBean(InputDestination.class);
OutputDestination outputDestination = context.getBean(OutputDestination.class);
Message<byte[]> inputMessage = MessageBuilder.withPayload("aa,bb,cc,dd".getBytes()).build();
inputDestination.send(inputMessage, "myInput");
assertThat(new String(outputDestination.receive(100, "myOutput").getPayload())).isEqualTo("aa");
assertThat(new String(outputDestination.receive(100, "myOutput").getPayload())).isEqualTo("bb");
assertThat(new String(outputDestination.receive(100, "myOutput").getPayload())).isEqualTo("cc");
assertThat(new String(outputDestination.receive(100, "myOutput").getPayload())).isEqualTo("dd");
assertThat(outputDestination.receive(100)).isNull();
}
}
@EnableAutoConfiguration
public static class NoEnableBindingConfiguration {