From e81976f7b5001280b917adaa1c8fe62500501b67 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 19 Sep 2024 16:14:34 -0400 Subject: [PATCH] Make MessageConverterHelper bean names distinct in binders. --- .../kafka/config/MessageConverterHelperConfiguration.java | 2 +- .../rabbit/config/MessageConverterHelperConfiguration.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java index 840b1feeb..ce3cc28ea 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java @@ -28,7 +28,7 @@ import org.springframework.context.annotation.Configuration; public class MessageConverterHelperConfiguration { @Bean - public MessageConverterHelper messageConverterHelper() { + public MessageConverterHelper kafkaMessageConverterHelper() { return new DefaultMessageConverterHelper(); } } diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java index ea1ca65ac..2cf17deea 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java @@ -27,7 +27,7 @@ import org.springframework.context.annotation.Configuration; public class MessageConverterHelperConfiguration { @Bean - public MessageConverterHelper messageConverterHelper() { + public MessageConverterHelper rabbitMessageConverterHelper() { return new DefaultMessageConverterHelper(); } }