From 19735a31d2d943919862ab3d6eeea43cc09420a0 Mon Sep 17 00:00:00 2001
From: Soby Chacko <soby.chacko@broadcom.com>
Date: Mon, 22 Jan 2024 17:36:53 -0500
Subject: [PATCH] Minor code cleanup in BindingServiceConfiguration

---
 .../config/BindingServiceConfiguration.java   | 19 ++++++-------------
 1 file changed, 6 insertions(+), 13 deletions(-)

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()));
 	}
 
 }