[CI] - 修改基础镜像为JDK, 方便使用arthas工具
This commit is contained in:
@@ -23,7 +23,7 @@ import java.util.concurrent.*;
|
||||
* 2. [build the redis stream listener]
|
||||
* 3. [call persistence]
|
||||
*/
|
||||
@Service
|
||||
//@Service
|
||||
@Slf4j
|
||||
@Lazy
|
||||
@Deprecated
|
||||
|
||||
@@ -47,7 +47,6 @@ public interface QuartzSchedulerService {
|
||||
* @param jobClass 任务job实现类
|
||||
* @param jobName 任务job名称(保证唯一性)
|
||||
* @param jobGroupName 任务job组名
|
||||
* @param startTime 任务开始时间,单位间隔为秒
|
||||
* @param cronJobExpression 任务时间表达式
|
||||
* @param jobData 任务参数
|
||||
* @return
|
||||
@@ -57,7 +56,6 @@ public interface QuartzSchedulerService {
|
||||
String jobName,
|
||||
String jobGroupName,
|
||||
String jobDescription,
|
||||
int startTime,
|
||||
String cronJobExpression,
|
||||
Map jobData
|
||||
);
|
||||
|
||||
@@ -15,7 +15,6 @@ import org.apache.commons.lang3.ObjectUtils;
|
||||
import org.apache.commons.lang3.RandomStringUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.quartz.*;
|
||||
import org.quartz.DateBuilder.IntervalUnit;
|
||||
import org.quartz.impl.matchers.GroupMatcher;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.scheduling.quartz.QuartzJobBean;
|
||||
@@ -71,7 +70,6 @@ public class QuartzSchedulerServiceImpl implements QuartzSchedulerService {
|
||||
scriptSchedulerDTO.getSchedulerUuid(),
|
||||
SCRIPT_SCHEDULE_MISSION_GROUP_NAME,
|
||||
scriptSchedulerDTO.getDescription(),
|
||||
0,
|
||||
// 立即开始本次任务 1ms wait
|
||||
scriptSchedulerDTO.getCronExpress(),
|
||||
dataMap
|
||||
@@ -271,14 +269,13 @@ public class QuartzSchedulerServiceImpl implements QuartzSchedulerService {
|
||||
jobName,
|
||||
jobGroupName,
|
||||
null,
|
||||
startTime,
|
||||
cronJobExpression,
|
||||
jobData
|
||||
);
|
||||
}
|
||||
|
||||
@Override
|
||||
public JobDetail addMission(Class<? extends QuartzJobBean> jobClass, String jobName, String jobGroupName, String jobDescription, int startTime, String cronJobExpression, Map jobData) {
|
||||
public JobDetail addMission(Class<? extends QuartzJobBean> jobClass, String jobName, String jobGroupName, String jobDescription, String cronJobExpression, Map jobData) {
|
||||
try {
|
||||
// 创建jobDetail实例,绑定Job实现类
|
||||
// 指明job的名称,所在组的名称,以及绑定job类
|
||||
@@ -303,21 +300,12 @@ public class QuartzSchedulerServiceImpl implements QuartzSchedulerService {
|
||||
// 使用cornTrigger规则
|
||||
// 触发器key
|
||||
// uniform the start time
|
||||
if (ObjectUtils.isEmpty(startTime)) {
|
||||
startTime = 1;
|
||||
}
|
||||
|
||||
Trigger trigger = newTrigger()
|
||||
.withIdentity(
|
||||
jobName,
|
||||
jobGroupName
|
||||
)
|
||||
.startAt(
|
||||
DateBuilder.futureDate(
|
||||
startTime,
|
||||
IntervalUnit.SECOND
|
||||
)
|
||||
)
|
||||
.withSchedule(
|
||||
CronScheduleBuilder.cronSchedule(cronJobExpression)
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user