diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java index a0a5c78ae..e3bc395ee 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java @@ -66,7 +66,6 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Import; import org.springframework.context.annotation.Role; -import org.springframework.context.annotation.Scope; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.core.env.Environment; import org.springframework.core.env.StandardEnvironment; @@ -136,14 +135,11 @@ public class BinderFactoryAutoConfiguration { @Bean(IntegrationContextUtils.MESSAGE_HANDLER_FACTORY_BEAN_NAME) - @Scope("prototype") public static MessageHandlerMethodFactory messageHandlerMethodFactory( @Qualifier(IntegrationContextUtils.ARGUMENT_RESOLVER_MESSAGE_CONVERTER_BEAN_NAME) CompositeMessageConverter compositeMessageConverter, @Nullable Validator validator, ConfigurableListableBeanFactory clbf) { DefaultMessageHandlerMethodFactory messageHandlerMethodFactory = new DefaultMessageHandlerMethodFactory(); -// CompositeMessageConverter messageConverter = -// compositeMessageConverterFactory.getMessageConverterForAllRegistered(); messageHandlerMethodFactory.setMessageConverter(compositeMessageConverter); /* diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ContentTypeConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ContentTypeConfiguration.java index 46949b391..067d608c6 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ContentTypeConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ContentTypeConfiguration.java @@ -39,14 +39,6 @@ import org.springframework.messaging.converter.MessageConverter; @Role(BeanDefinition.ROLE_INFRASTRUCTURE) class ContentTypeConfiguration { -// @Bean -// public CompositeMessageConverterFactory compositeMessageConverterFactory( -// ObjectProvider objectMapperObjectProvider, List customMessageConverters) { -// -// return new CompositeMessageConverterFactory(customMessageConverters, -// objectMapperObjectProvider.getIfAvailable(ObjectMapper::new)); -// } - @Bean(name = IntegrationContextUtils.ARGUMENT_RESOLVER_MESSAGE_CONVERTER_BEAN_NAME) public ConfigurableCompositeMessageConverter configurableCompositeMessageConverter( ObjectProvider objectMapperObjectProvider, @@ -59,8 +51,6 @@ class ContentTypeConfiguration { messageConverters.addAll(customMessageConverters); return new ConfigurableCompositeMessageConverter(messageConverters); - - } }