From 2adf718d06cb616d0c13f5f57977e3f75e89f0b3 Mon Sep 17 00:00:00 2001 From: majingjing Date: Thu, 21 Jan 2021 13:54:46 +0800 Subject: [PATCH] fix https://github.com/xuxueli/xxl-job/issues/2210 GlueJobHandler can not exec init(),destroy() #2210 --- .../job/core/handler/impl/GlueJobHandler.java | 67 +++++++++++-------- 1 file changed, 38 insertions(+), 29 deletions(-) diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java b/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java index e6a2efdb0d..79b2d73f09 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java @@ -1,29 +1,38 @@ -package com.xxl.job.core.handler.impl; - -import com.xxl.job.core.context.XxlJobHelper; -import com.xxl.job.core.handler.IJobHandler; - -/** - * glue job handler - * - * @author xuxueli 2016-5-19 21:05:45 - */ -public class GlueJobHandler extends IJobHandler { - - private long glueUpdatetime; - private IJobHandler jobHandler; - public GlueJobHandler(IJobHandler jobHandler, long glueUpdatetime) { - this.jobHandler = jobHandler; - this.glueUpdatetime = glueUpdatetime; - } - public long getGlueUpdatetime() { - return glueUpdatetime; - } - - @Override - public void execute() throws Exception { - XxlJobHelper.log("----------- glue.version:"+ glueUpdatetime +" -----------"); - jobHandler.execute(); - } - -} +package com.xxl.job.core.handler.impl; + +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.IJobHandler; + +/** + * glue job handler + * + * @author xuxueli 2016-5-19 21:05:45 + */ +public class GlueJobHandler extends IJobHandler { + + private long glueUpdatetime; + private IJobHandler jobHandler; + public GlueJobHandler(IJobHandler jobHandler, long glueUpdatetime) { + this.jobHandler = jobHandler; + this.glueUpdatetime = glueUpdatetime; + } + public long getGlueUpdatetime() { + return glueUpdatetime; + } + + @Override + public void execute() throws Exception { + XxlJobHelper.log("----------- glue.version:"+ glueUpdatetime +" -----------"); + jobHandler.execute(); + } + + @Override + public void init() throws Exception { + this.jobHandler.init(); + } + + @Override + public void destroy() throws Exception { + this.jobHandler.destroy(); + } +}