org.apache.helix.model.Message.setExecutionTimeout()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(75)

本文整理了Java中org.apache.helix.model.Message.setExecutionTimeout()方法的一些代码示例,展示了Message.setExecutionTimeout()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.setExecutionTimeout()方法的具体详情如下:
包路径:org.apache.helix.model.Message
类名称:Message
方法名:setExecutionTimeout

Message.setExecutionTimeout介绍

[英]Set the time to wait before stopping execution of this message
[中]设置停止执行此消息之前的等待时间

代码示例

代码示例来源:origin: org.apache.helix/helix-core

for (Message tempMessage : list) {
 tempMessage.setRetryCount(retryCount);
 tempMessage.setExecutionTimeout(timeOut);
 tempMessage.setSrcInstanceType(_manager.getInstanceType());
 if (correlationId != null) {

代码示例来源:origin: apache/helix

for (Message tempMessage : list) {
 tempMessage.setRetryCount(retryCount);
 tempMessage.setExecutionTimeout(timeOut);
 tempMessage.setSrcInstanceType(_manager.getInstanceType());
 if (correlationId != null) {

代码示例来源:origin: apache/helix

currentState, nextState, idealState, partition);
if (timeout > 0) {
 message.setExecutionTimeout(timeout);

代码示例来源:origin: org.apache.helix/helix-core

currentState, nextState, idealState, partition);
if (timeout > 0) {
 message.setExecutionTimeout(timeout);

代码示例来源:origin: apache/helix

msg.setTgtName("Localhost_1123");
msg.setSrcName("127.101.1.23_2234");
msg.setExecutionTimeout((i + 1) * 600);
msgList.add(msg);

代码示例来源:origin: apache/helix

msg.setTgtName("Localhost_1123");
msg.setSrcName("127.101.1.23_2234");
msg.setExecutionTimeout((i + 1) * 600);
msg.setRetryCount(1);
msgList.add(msg);

相关文章