diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java index 3eb5c6a51..bd730234a 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java @@ -351,8 +351,8 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl private void customizeParentChildContextRelationship(SpringApplicationBuilder applicationBuilder, ApplicationContext context) { if (context != null) { Map customizers = context.getBeansOfType(ListenerContainerCustomizer.class); - if (!CollectionUtils.isEmpty(customizers)) { - applicationBuilder.initializers(childContext -> { + applicationBuilder.initializers(childContext -> { + if (!CollectionUtils.isEmpty(customizers)) { for (Entry customizerEntry : customizers.entrySet()) { ListenerContainerCustomizer customizerWrapper = new ListenerContainerCustomizer() { @Override @@ -372,11 +372,11 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl ((GenericApplicationContext) childContext).registerBean(customizerEntry.getKey(), ListenerContainerCustomizer.class, () -> customizerWrapper); } - GenericConversionService cs = (GenericConversionService) ((GenericApplicationContext) childContext).getBeanFactory().getConversionService(); - SpelConverter spelConverter = new SpelConverter(); - cs.addConverter(spelConverter); - }); - } + } + GenericConversionService cs = (GenericConversionService) ((GenericApplicationContext) childContext).getBeanFactory().getConversionService(); + SpelConverter spelConverter = new SpelConverter(); + cs.addConverter(spelConverter); + }); } }