Skip to content

Commit db3a528

Browse files
committed
gH-2222 Additional changes related to removal of TARGET_PROTOCOL
1 parent 45b6597 commit db3a528

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1208,8 +1208,8 @@ void headerPropagation() {
12081208
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
12091209
TestChannelBinderConfiguration.getCompleteConfiguration(SingleFunctionConfiguration.class))
12101210
.web(WebApplicationType.NONE).run("--spring.jmx.enabled=false",
1211-
"--spring.cloud.function.definition=func",
1212-
"--spring.cloud.function.configuration.func.copy-input-headers=true")) {
1211+
"--spring.cloud.function.definition=func"
1212+
)) {
12131213

12141214
InputDestination inputDestination = context.getBean(InputDestination.class);
12151215
OutputDestination outputDestination = context.getBean(OutputDestination.class);

core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/RoutingFunctionEnvironmentPostProcessor.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,9 @@ public void postProcessEnvironment(ConfigurableEnvironment environment, SpringAp
4141
((StandardEnvironment) environment).getSystemProperties()
4242
.putIfAbsent("spring.cloud.function.routing.enabled", "true");
4343
}
44+
// perhaps mpve it to separate class as it doesn't have much to do with RoutingFunction
45+
((StandardEnvironment) environment).getSystemProperties()
46+
.putIfAbsent("spring.cloud.function.configuration.default.copy-input-headers", "true");
4447
}
4548

4649
}

0 commit comments

Comments
 (0)