alibaba / alibaba/spring-cloud-alibaba

RocketMQ not support MessageConverter

Open
#885 3 comments 1 reaction 1 assignee Claimed by @zkzlx View on GitHub
area/rocketmq kind/enhancement
Dominant language
Java
Stars
29.2k
Forks
8.5k
Avg merge
1d 23h
Merged PRs (30d)
12

Description

**Which Component**
RocketMQ

**Is your feature request related to a problem? Please describe.**
https://cloud.spring.io/spring-cloud-static/Greenwich.SR2/multi/multi_content-type-management.html.

RocketMQMessageHandler发送都是用RocketMQTemplate,然后RocketMQTemplate里面序列化是写死用jackson的Mapper的,这似乎不符合Spring cloud stream的规范.
这里的说明写的是stream的message的body和http请求的body是一样的机制,有一整个list的转换器.只不过一个接口是org.springframework.messaging.converter.MessageConverter,一个接口是org.springframework.http.converter.HttpMessageConverter.
但是RocketMQTemplate是写死用jackson,没有用Spring的MessageConverter机制.

RocketMQMessageHandler uses RocketMQ Emplate to send messages, and then RocketMQ Emplate is serialized to write dead Jackson Mapper, which does not seem to conform to the Spring cloud stream specification.

The explanation here is that the body of stream message is the same mechanism as the body of HTTP request, with an entire list converter. Only one interface is org. spring framework. messaging. converter. MessageConverter, and one interface is org. spring framework. http. converter. HttpMessageConverter.

But RocketMQTemplate is a dead-end jackson, not Spring's Message Converter mechanism.

**Describe the solution you'd like**
support MessageConverter.

**Additional context**
https://cloud.spring.io/spring-cloud-static/Greenwich.SR2/multi/multi_content-type-management.html.

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.