Which Component
rocketmq
Describe the bug
rocketmq发送延迟消息无效。
To Reproduce
Steps to reproduce the behavior:
source.output().send(MessageBuilder
.withPayload(objectMapper.writeValueAsString(new Person(99, "Jim")))
.setHeader("index", 9999)
.setHeader("DELAY", "5")
.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
.build());
Expected behavior
发送延迟消息未见生效。
Screenshots
no
Additional context
MacOS 、Java8 、 spring-cloud-alibaba.version:2.1.0.RELEASE spring-cloud.version:Greenwich.SR2
2条答案
按热度按时间pcrecxhr1#
需要添加一个配置，可以查看这个issue https://github.com/alibaba/spring-cloud-alibaba/issues/680
0s0u357o2#
please try the beta version #2029 to see if it solves your problem or provide more information to help to find the latent bug.