[GitHub] [rocketmq-spring] Jenyow edited a comment on issue #426: Could not deserialize localdatetime when using jdk8

[GitBox <gi...@apache.org>]

Jenyow edited a comment on issue #426:
URL: https://github.com/apache/rocketmq-spring/issues/426#issuecomment-1024352957


   The code use **new MappingJackson2MessageConverter()**, so it can't use my custom  MappingJackson2MessageConverter.
   ```
   package org.apache.rocketmq.spring.support;
   
   import java.util.ArrayList;
   import java.util.List;
   import org.springframework.messaging.converter.ByteArrayMessageConverter;
   import org.springframework.messaging.converter.CompositeMessageConverter;
   import org.springframework.messaging.converter.ContentTypeResolver;
   import org.springframework.messaging.converter.MappingJackson2MessageConverter;
   import org.springframework.messaging.converter.MessageConverter;
   import org.springframework.messaging.converter.StringMessageConverter;
   import org.springframework.util.ClassUtils;
   
   public class RocketMQMessageConverter {
       private static final boolean JACKSON_PRESENT;
       private static final boolean FASTJSON_PRESENT;
       private final CompositeMessageConverter messageConverter;
   
       public RocketMQMessageConverter() {
           List<MessageConverter> messageConverters = new ArrayList();
           ByteArrayMessageConverter byteArrayMessageConverter = new ByteArrayMessageConverter();
           byteArrayMessageConverter.setContentTypeResolver((ContentTypeResolver)null);
           messageConverters.add(byteArrayMessageConverter);
           messageConverters.add(new StringMessageConverter());
           if (JACKSON_PRESENT) {
               messageConverters.add(new MappingJackson2MessageConverter());
           }
   
           if (FASTJSON_PRESENT) {
               try {
                   messageConverters.add((MessageConverter)ClassUtils.forName("com.alibaba.fastjson.support.spring.messaging.MappingFastJsonMessageConverter", ClassUtils.getDefaultClassLoader()).newInstance());
               } catch (IllegalAccessException | InstantiationException | ClassNotFoundException var4) {
               }
           }
   
           this.messageConverter = new CompositeMessageConverter(messageConverters);
       }
   
       public MessageConverter getMessageConverter() {
           return this.messageConverter;
       }
   
       static {
           ClassLoader classLoader = RocketMQMessageConverter.class.getClassLoader();
           JACKSON_PRESENT = ClassUtils.isPresent("com.fasterxml.jackson.databind.ObjectMapper", classLoader) && ClassUtils.isPresent("com.fasterxml.jackson.core.JsonGenerator", classLoader);
           FASTJSON_PRESENT = ClassUtils.isPresent("com.alibaba.fastjson.JSON", classLoader) && ClassUtils.isPresent("com.alibaba.fastjson.support.config.FastJsonConfig", classLoader);
       }
   }
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org