From efdb99f8cecc4afb592afad79c761081d5d5cf22 Mon Sep 17 00:00:00 2001 From: lee <4766465@qq.com> Date: Wed, 18 Dec 2024 13:27:00 +0800 Subject: [PATCH] init --- xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java | 38 ++++++++++++++++++++++++++++++++++++++ 1 files changed, 38 insertions(+), 0 deletions(-) diff --git a/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java b/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java new file mode 100644 index 0000000..79b2d73 --- /dev/null +++ b/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/GlueJobHandler.java @@ -0,0 +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(); + } + + @Override + public void init() throws Exception { + this.jobHandler.init(); + } + + @Override + public void destroy() throws Exception { + this.jobHandler.destroy(); + } +} -- Gitblit v1.9.3