diff --git a/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java b/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java index 2faebc1ab421bae567e1c368bf09445d603eebf4..48ecd2e375b966fff86479b4c933d6aed1493cf5 100644 --- a/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java +++ b/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java @@ -54,4 +54,11 @@ public class NotifyPlatform { * Receivers, split by , */ private String receivers = "all"; + + /** + * 超时时间<
+ * 同时设置: 读取超时 + * 同时设置: 连接超时 + */ + private Integer timeOut = 10; } diff --git a/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractNotifier.java b/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractNotifier.java index 3f7af1decd58f35d4b83a2b24c3dc3115c8138ed..2a629a71ca357f806aae1710ceb6cfb4d0d153a9 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractNotifier.java +++ b/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractNotifier.java @@ -38,6 +38,7 @@ public abstract class AbstractNotifier implements Notifier { @Override public final void send(NotifyPlatform platform, String content) { try { + HttpGlobalConfig.setTimeout(platform.getTimeOut()); send0(platform, content); } catch (Exception e) { log.error("DynamicTp notify, {} send failed.", platform(), e);