You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/12/05 07:17:38 UTC
[GitHub] [rocketmq-spring] john1337 opened a new issue, #506: rocketmqTemplate连发送延迟消息的接口都没有么
john1337 opened a new issue, #506:
URL: https://github.com/apache/rocketmq-spring/issues/506
Message message = new Message(TOPIC, ("Hello scheduled message " + i).getBytes(StandardCharsets.UTF_8));
// This message will be delivered to consumer 10 seconds later.
//message.setDelayTimeSec(10);
// The effect is the same as the above
// message.setDelayTimeMs(10_000L);
// Set the specific delivery time, and the effect is the same as the above
message.setDeliverTimeMs(System.currentTimeMillis() + 3600_000L);
想实现类似的功能没看到哪个接口支持，只找到了固定延迟级别的接口：
SendResult syncSend(String destination, Message<?> message, long timeout, int delayLevel)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] dfjfj commented on issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
Posted by GitBox <gi...@apache.org>.
dfjfj commented on issue #506:
URL: https://github.com/apache/rocketmq-spring/issues/506#issuecomment-1346139556
加油💪, 期待尽快适配5.0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] francisoliverlee closed issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.
francisoliverlee closed issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
URL: https://github.com/apache/rocketmq-spring/issues/506
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] MartinDai commented on issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
Posted by GitBox <gi...@apache.org>.
MartinDai commented on issue #506:
URL: https://github.com/apache/rocketmq-spring/issues/506#issuecomment-1354275536
5.0也不支持任意指定延迟时间吧，商业版的才有
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] mxsm commented on issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
Posted by "mxsm (via GitHub)" <gi...@apache.org>.
mxsm commented on issue #506:
URL: https://github.com/apache/rocketmq-spring/issues/506#issuecomment-1407590361
> 5.0也不支持任意指定延迟时间吧，商业版的才有
5.0版本已经支持
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] RongtongJin commented on issue #506: rocketmqTemplate连发送延迟消息的接口都没有么
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #506:
URL: https://github.com/apache/rocketmq-spring/issues/506#issuecomment-1341953909
> Message message = new Message(TOPIC, ("Hello scheduled message " + i).getBytes(StandardCharsets.UTF_8)); // This message will be delivered to consumer 10 seconds later. //message.setDelayTimeSec(10); // The effect is the same as the above // message.setDelayTimeMs(10_000L); // Set the specific delivery time, and the effect is the same as the above message.setDeliverTimeMs(System.currentTimeMillis() + 3600_000L);
>
> 想实现类似的功能没看到哪个接口支持，只找到了固定延迟级别的接口： SendResult syncSend(String destination, Message<?> message, long timeout, int delayLevel)
当前RocketMQ-Spring支持到4.x，会尽快适配5.0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] zhouchunhai commented on issue #506: RocketmqTemplate does not have a method to send delay messages in version 5.0
Posted by GitBox <gi...@apache.org>.
zhouchunhai commented on issue #506:
URL: https://github.com/apache/rocketmq-spring/issues/506#issuecomment-1382678677
@I will resolve it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org