spring cloud - How to set rockemq message expired time?

Question

Here I am using spring-cloud-starter-stream-rocketmq and spring-message to send message dn, e.g.

Message m = MessageBuilder.withPayload(obj).setHeader(RocketMQHeaders.TAGS, tag).build();
MessageChannel.output().send(m);

But I want to set the message expire time in the queue if that not be consumed.

I know the rocketmq could set the ttl, but I don't know whether that can be set for different message and how can be used in the code before?

Answer 1

等待大神答复