You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "zhurunhua (via GitHub)" <gi...@apache.org> on 2023/02/27 11:23:00 UTC
[GitHub] [rocketmq-clients] zhurunhua opened a new issue, #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
zhurunhua opened a new issue, #369:
URL: https://github.com/apache/rocketmq-clients/issues/369
In the introduction document page. I found these code that can specify a Unix timestamp to send a delay message:
```
// Send delay messages.
MessageBuilder messageBuilder = null;
// Specify a millisecond-level Unix timestamp. In this example, the specified timestamp indicates that the message will be delivered in 10 minutes from the current time.
Long deliverTimeStamp = System.currentTimeMillis() + 10L * 60 * 1000;
Message message = messageBuilder.setTopic("topic")
// Specify the message index key. The system uses the key to locate the message.
.setKeys("messageKey")
// Specify the message tag. The consumer can use the tag to filter messages.
.setTag("messageTag")
.setDeliveryTimestamp(deliverTimeStamp)
// Configure the message body.
.setBody("messageBody".getBytes())
.build();
try {
// Send the messages. Focus on the result of message sending and exceptions such as failures.
SendReceipt sendReceipt = producer.send(message);
System.out.println(sendReceipt.getMessageId());
} catch (ClientException e) {
e.printStackTrace();
}
```
But I didn't find the implementation for this feature in the source code of version 5.0. So please tell me the truth
Thanks a lot
--
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-clients] xdkxlk commented on issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
Posted by "xdkxlk (via GitHub)" <gi...@apache.org>.
xdkxlk commented on issue #369:
URL: https://github.com/apache/rocketmq-clients/issues/369#issuecomment-1447489262
Moreover, because there isn't the implementation of time wheel at that time when the proxy module development. If you need to use arbitrary precision timing, need to set the useDelayLevel to false in the config of proxy
In apache/rocketmq#6204, the default value of useDelayLevel will be changed to false
--
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-clients] aaron-ai commented on issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
Posted by "aaron-ai (via GitHub)" <gi...@apache.org>.
aaron-ai commented on issue #369:
URL: https://github.com/apache/rocketmq-clients/issues/369#issuecomment-1446213191
@xdkxlk PTAL
--
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-clients] zhurunhua commented on issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
Posted by "zhurunhua (via GitHub)" <gi...@apache.org>.
zhurunhua commented on issue #369:
URL: https://github.com/apache/rocketmq-clients/issues/369#issuecomment-1447521465
thanks for your explain
--
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-clients] zhurunhua closed issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
Posted by "zhurunhua (via GitHub)" <gi...@apache.org>.
zhurunhua closed issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
URL: https://github.com/apache/rocketmq-clients/issues/369
--
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-clients] aaron-ai commented on issue #369: Java：Is it really possible to support any delay time by specifying a Unix timestamp to send a delay message?
Posted by "aaron-ai (via GitHub)" <gi...@apache.org>.
aaron-ai commented on issue #369:
URL: https://github.com/apache/rocketmq-clients/issues/369#issuecomment-1447471180
@zhurunhua or you could refer to https://browser.alibaba-inc.com/?Url=https://shimo.im/docs/gXqme9PKKpIeD7qo/read
--
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