Using rockermq5.0 to send a delayed message, the message was found to have no delay

[Hybdream95]

I wrote the consumer and producer code with reference to the Quick Start code in the 5.0 documentation, and modified the producer code because of the need to send delayed messages. After the change was tested, it was found that the message was consumed without delay. This is the code I changed:

Message message = provider.newMessageBuilder()
.setTopic(topic)
// 设置消息Tag，用于消费端根据指定Tag过滤消息。
.setTag("*")
// 消息体。
.setBody(body)
.setDeliveryTimestamp(l)
.build();

// 发送延迟消息
CompletableFuture sendReceiptCompletableFuture = producer.sendAsync(message);