SCF-GH-599 Add test to validate the header propagation behavior

This commit is contained in:
Oleg Zhurakousky
2020-10-24 08:26:01 +02:00
parent f22c8f6ace
commit 85afc53ab3

View File

@@ -943,6 +943,23 @@ public class ImplicitFunctionBindingTests {
}
}
@Test
public void testHeaderPropagation() {
System.clearProperty("spring.cloud.function.definition");
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration.class))
.web(WebApplicationType.NONE).run("--spring.jmx.enabled=false",
"--spring.cloud.function.definition=func")) {
InputDestination inputDestination = context.getBean(InputDestination.class);
OutputDestination outputDestination = context.getBean(OutputDestination.class);
inputDestination.send(MessageBuilder.withPayload("hello").setHeader("foo", "bar").build());
assertThat(outputDestination.receive(1000).getHeaders().get("foo")).isEqualTo("bar");
}
}
@EnableAutoConfiguration
public static class SupplierAndPojoConfiguration {
@Bean