bug #I4QOP6 when超时时抛出的错是NPT

This commit is contained in:
bryan31
2022-01-13 15:30:36 +08:00
parent de8f402c92
commit ea02583e16
2 changed files with 30 additions and 0 deletions

View File

@@ -1,5 +1,9 @@
package com.yomahub.liteflow.entity.flow.parallel;
import cn.hutool.core.util.StrUtil;
import com.yomahub.liteflow.exception.WhenTimeoutException;
import com.yomahub.liteflow.property.LiteflowConfigGetter;
/**
* 并行异步CompletableFuture里的值对象
* @author Bryan.Zhang
@@ -37,6 +41,11 @@ public class WhenFutureObj {
result.setSuccess(false);
result.setTimeout(true);
result.setExecutorName(executorName);
result.setEx(new WhenTimeoutException(
StrUtil.format("Timed out when executing the component[{}],when-max-timeout-seconds config is:{}(s)",
executorName,
LiteflowConfigGetter.get().getWhenMaxWaitSeconds()))
);
return result;
}

View File

@@ -0,0 +1,21 @@
package com.yomahub.liteflow.exception;
public class WhenTimeoutException extends RuntimeException {
private static final long serialVersionUID = 1L;
/** 异常信息 */
private String message;
public WhenTimeoutException(String message) {
this.message = message;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
}