Skip to content

S
service-campaign
Commit b688345d authored by Nguyen Ha's avatar Nguyen Ha
Browse files
Options

fix sonar

parent 405c8e2d
Hide whitespace changes
Inline Side-by-side
Showing with 27 additions and 26 deletions
src/main/java/com/viettel/campaign/config/JobConfig.java
View file @ b688345d
...@@ -48,33 +48,34 @@ public class JobConfig implements SchedulingConfigurer { ...@@ -48,33 +48,34 @@ public class JobConfig implements SchedulingConfigurer {
// taskRegistrar.setTaskScheduler(threadPoolTaskScheduler); // taskRegistrar.setTaskScheduler(threadPoolTaskScheduler);
// } // }
private void job1(TaskScheduler scheduler) { // private void job1(TaskScheduler scheduler) {
job1 = scheduler.schedule(() -> { // job1 = scheduler.schedule(() -> {
log.info("processing job1 ..."); // log.info("processing job1 ...");
log.info(Thread.currentThread().getName() + " The Task1 executed at " + new Date()); // log.info(Thread.currentThread().getName() + " The Task1 executed at " + new Date());
try { // try {
Thread.sleep(10000); // Thread.sleep(10000);
} catch (InterruptedException e) { // } catch (InterruptedException e) {
// TODO Auto-generated catch block // // TODO Auto-generated catch block
e.printStackTrace(); //// e.printStackTrace();
} // log.error("Interrupted! ...${}", e);
}, triggerContext -> { // }
// }, triggerContext -> {
String cronExp = "0/5 * * * * ?";// Can be pulled from a db . //
return new CronTrigger(cronExp).nextExecutionTime(triggerContext); // String cronExp = "0/5 * * * * ?";// Can be pulled from a db .
}); // return new CronTrigger(cronExp).nextExecutionTime(triggerContext);
} // });
// }
private void job2(TaskScheduler scheduler) {
job2 = scheduler.schedule(() -> {
log.info(Thread.currentThread().getName() + " The Job executed at " + new Date());
campaignJob().process();
}, triggerContext -> { // private void job2(TaskScheduler scheduler) {
String cronExp = "0/1 * * * * ?";// Can be pulled from a db . This will run every minute // job2 = scheduler.schedule(() -> {
return new CronTrigger(cronExp).nextExecutionTime(triggerContext); // log.info(Thread.currentThread().getName() + " The Job executed at " + new Date());
}); // campaignJob().process();
} //
// }, triggerContext -> {
// String cronExp = "0/1 * * * * ?";// Can be pulled from a db . This will run every minute
// return new CronTrigger(cronExp).nextExecutionTime(triggerContext);
// });
// }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment