From 5eb73ca7a1c6496fd0dad5d05dbf79b2ec92b014 Mon Sep 17 00:00:00 2001 From: Donghuang Date: Fri, 17 Jun 2022 10:07:18 +0800 Subject: [PATCH] add text/event-stream content type support --- .../com/pudonghot/ambition/crm/AmbitionCRM.java | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/server/crm/src/main/java/com/pudonghot/ambition/crm/AmbitionCRM.java b/server/crm/src/main/java/com/pudonghot/ambition/crm/AmbitionCRM.java index cc25572..7760393 100644 --- a/server/crm/src/main/java/com/pudonghot/ambition/crm/AmbitionCRM.java +++ b/server/crm/src/main/java/com/pudonghot/ambition/crm/AmbitionCRM.java @@ -15,6 +15,7 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; +import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -47,11 +48,17 @@ public class AmbitionCRM implements WebMvcConfigurer { return threadPoolTaskExecutor; } + /** + * {@inheritDoc} + */ @Override - public void configureMessageConverters(final List> messageConverters) { - val jackson2HttpMessageConverter = new MappingJackson2HttpMessageConverter(); - jackson2HttpMessageConverter.setSupportedMediaTypes( - Arrays.asList(MediaType.valueOf("text/event-stream"))); - messageConverters.add(jackson2HttpMessageConverter); + public void extendMessageConverters(final List> converters) { + converters.forEach(converter -> { + if (converter instanceof MappingJackson2HttpMessageConverter) { + val supportedMediaTypes = new ArrayList<>(converter.getSupportedMediaTypes()); + supportedMediaTypes.add(MediaType.valueOf("text/event-stream")); + ((MappingJackson2HttpMessageConverter) converter).setSupportedMediaTypes(supportedMediaTypes); + } + }); } }