mirrors/pig
1
0
Fork 0
mirror of https://gitee.com/log4j/pig.git synced 2024-12-23 13:03:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修改xxl-job服务器地址设置setAddress改为setAdminAddresses

Browse Source
This commit is contained in:
yang 2020-11-21 22:57:26 +08:00
parent d7bc5f822f
commit 0588c4a707
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pig-common/pig-common-job/src/main/java/com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java
View File

@ -51,10 +51,10 @@ public class XxlJobAutoConfiguration {
.flatMap(s -> discoveryClient.getInstances(s).stream()).map(instance -> String .flatMap(s -> discoveryClient.getInstances(s).stream()).map(instance -> String
.format("http://%s:%s/%s", instance.getHost(), instance.getPort(), XXL_JOB_ADMIN)) .format("http://%s:%s/%s", instance.getHost(), instance.getPort(), XXL_JOB_ADMIN))
.collect(Collectors.joining(",")); .collect(Collectors.joining(","));
xxlJobSpringExecutor.setAddress(serverList); xxlJobSpringExecutor.setAdminAddresses(serverList);
} }
else { else {
xxlJobSpringExecutor.setAddress(xxlJobProperties.getAdmin().getAddresses()); xxlJobSpringExecutor.setAdminAddresses(xxlJobProperties.getAdmin().getAddresses());
} }
return xxlJobSpringExecutor; return xxlJobSpringExecutor;