diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingServiceConfiguration.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingServiceConfiguration.java
index 0c424b6bb..bd890bc09 100644
--- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingServiceConfiguration.java
+++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingServiceConfiguration.java
@@ -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()));
 	}
 
 }