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

Minor code cleanup in BindingServiceConfiguration

Browse Source
This commit is contained in:
Soby Chacko
2024-01-22 17:36:53 -05:00
parent 1cda3acb22
commit 19735a31d2
1 changed files with 6 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingServiceConfiguration.java
View File

@@ -240,19 +240,12 @@ public class BindingServiceConfiguration {
@Bean
public ApplicationListener<ContextRefreshedEvent> appListener(
SpringIntegrationProperties springIntegrationProperties) {
return new ApplicationListener<ContextRefreshedEvent>() {
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
event.getApplicationContext()
.getBeansOfType(AbstractReplyProducingMessageHandler.class)
.values()
.forEach(mh -> mh
.addNotPropagatedHeaders(springIntegrationProperties
.getMessageHandlerNotPropagatedHeaders()));
}
};
return event -> event.getApplicationContext()
.getBeansOfType(AbstractReplyProducingMessageHandler.class)
.values()
.forEach(mh -> mh
.addNotPropagatedHeaders(springIntegrationProperties
.getMessageHandlerNotPropagatedHeaders()));
}
}