From 735b3bdd49f1073d3d5d9c835e576e2a211d97dd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AB=98=E8=8D=A3=E7=90=B3?= Date: Mon, 18 Sep 2023 20:39:24 +0800 Subject: [PATCH] =?UTF-8?q?feature:xxl=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/dxhy/order/consumer/config/XxlJobConfig.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/config/XxlJobConfig.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/config/XxlJobConfig.java index 31c1079e..da8cd73a 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/config/XxlJobConfig.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/config/XxlJobConfig.java @@ -1,6 +1,7 @@ package com.dxhy.order.consumer.config; -import com.xxl.job.core.executor.XxlJobExecutor; + +import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; @@ -41,10 +42,10 @@ public class XxlJobConfig { private int logRetentionDays; - @Bean(initMethod = "start", destroyMethod = "destroy") - public XxlJobExecutor xxlJobExecutor() { + @Bean + public XxlJobSpringExecutor xxlJobExecutor() { log.info(">>>>>>>>>>> xxl-job config init."); - XxlJobExecutor xxlJobExecutor = new XxlJobExecutor(); + XxlJobSpringExecutor xxlJobExecutor = new XxlJobSpringExecutor(); xxlJobExecutor.setAdminAddresses(adminAddresses); xxlJobExecutor.setAppname(appName); xxlJobExecutor.setIp(ip);