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

GH-2113 Added test to validate user reported condition

Browse Source 
Resolves #2113
This commit is contained in:
Oleg Zhurakousky
2021-02-10 14:51:52 +01:00
parent 1c4ac7368e
commit 210d421df9
1 changed files with 15 additions and 12 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/ScenarioTests.java
View File

@@ -75,29 +75,23 @@ public class ScenarioTests {
}
@Test
public void test2112() {
public void test2113() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(TestConfiguration.class))
.web(WebApplicationType.NONE)
.run("--spring.jmx.enabled=false",
"--spring.cloud.function.definition=messageFunction")) {
"--spring.cloud.function.definition=genericTypeFunction")) {
InputDestination input = context.getBean(InputDestination.class);
OutputDestination output = context.getBean(OutputDestination.class);
input.send(new GenericMessage<byte[]>("hello-1".getBytes()), "messageFunction-in-0");
output.clear("messageFunction-out-0");
input.send(new GenericMessage<byte[]>("hello-2".getBytes()), "messageFunction-in-0");
assertThat(new String(output.receive(1000, "messageFunction-out-0").getPayload())).isEqualTo("hello-2");
input.send(new GenericMessage<byte[]>("hello-1".getBytes()), "messageFunction-in-0");
input.send(new GenericMessage<byte[]>("hello-2".getBytes()), "messageFunction-in-0");
output.clear();
input.send(new GenericMessage<byte[]>("hello-3".getBytes()), "messageFunction-in-0");
assertThat(new String(output.receive(1000, "messageFunction-out-0").getPayload())).isEqualTo("hello-3");
input.send(new GenericMessage<byte[]>("hello".getBytes()), "genericTypeFunction-in-0");
assertThat(new String(output.receive(1000, "genericTypeFunction-out-0").getPayload())).isEqualTo("hello_hello");
}
}
@EnableAutoConfiguration
@Configuration
public static class TestConfiguration {
@@ -109,6 +103,15 @@ public class ScenarioTests {
public Function<Message<?>, Message<?>> messageFunction() {
return message -> message;
}
@SuppressWarnings("unchecked")
@Bean
public <I, O> Function<I, O> genericTypeFunction() {
return v -> {
System.out.println(v);
return (O) ("hello_" + v);
};
}
}
@EnableAutoConfiguration