Delay messages can not send successful #394
Description
The issue tracker is ONLY used for bug report and feature request.
Any question or RocketMQ proposal please use our mailing lists.
BUG REPORT
- Please describe the issue you observed:
- What did you do (The steps to reproduce)?
I try to sended a delay message to my rocketmq - What did you expect to see?
send delay message successfully - What did you see instead?
send delay message failed and no any exception
-
Please tell us about your environment:
java:8
springboot: 2.3.2.RELEASE
rocketmq-spring-boot-starter:2.2.0
rocketMQ-broker and nameserver: 4.4.0 -
Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
rocketMQTemplate.asyncSend("DelayMsg", MessageBuilder.withPayload("delayMsg").build(), new SendCallback() {
@Override
public void onSuccess(SendResult sendResult) {
System.out.printf("发送结果:%n%s ",sendResult);
}
@Override
public void onException(Throwable e) {
e.printStackTrace();
}
},3000L,3);
System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
return "success";test result as follow:
发送结果:
SendResult [sendStatus=SEND_OK, msgId=7F000001141C18B4AAC2563CF3030000, offsetMsgId=65224A7400002A9F000000000001782F, messageQueue=MessageQueue [topic=DelayMsg, brokerName=broker-a , queueId=2], queueOffset=5]
but my rocketMQ did not have any message be sended
FEATURE REQUEST
-
Please describe the feature you are requesting.
-
Provide any additional detail on your proposed use case for this feature.
-
Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?