|
@@ -3,16 +3,12 @@ package cn.com.qmth.examcloud.task.starter.config;
|
|
|
import java.util.List;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
-import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.boot.ApplicationArguments;
|
|
|
import org.springframework.boot.ApplicationRunner;
|
|
|
-import org.springframework.cloud.client.ServiceInstance;
|
|
|
-import org.springframework.cloud.client.discovery.DiscoveryClient;
|
|
|
import org.springframework.core.annotation.Order;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
-import cn.com.qmth.examcloud.commons.exception.ExamCloudRuntimeException;
|
|
|
import cn.com.qmth.examcloud.task.dao.ScheduleJobRepo;
|
|
|
import cn.com.qmth.examcloud.task.dao.entity.ScheduleJobEntity;
|
|
|
import cn.com.qmth.examcloud.web.bootstrap.PropertyHolder;
|
|
@@ -36,9 +32,6 @@ public class JobsStartup implements ApplicationRunner {
|
|
|
@Autowired
|
|
|
private QuartzManager quartzManager;
|
|
|
|
|
|
- @Autowired
|
|
|
- private DiscoveryClient discoveryClient;
|
|
|
-
|
|
|
public void start() {
|
|
|
|
|
|
Boolean enabled = PropertyHolder.getBoolean("task.scheduleJob.enabled", true);
|
|
@@ -47,14 +40,6 @@ public class JobsStartup implements ApplicationRunner {
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- String appName = PropertyHolder.getString("spring.application.name");
|
|
|
- if (StringUtils.isNotBlank(appName)) {
|
|
|
- List<ServiceInstance> instances = discoveryClient.getInstances(appName);
|
|
|
- if (!instances.isEmpty()) {
|
|
|
- throw new ExamCloudRuntimeException("multiple task instances!");
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
new Thread(new Runnable() {
|
|
|
|
|
|
@Override
|