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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
