Skip to content

Commit 7b600d9

Browse files
author
胡贵
committed
提交一把 修复 提交本地任务 死锁bug, 修复 注册中心重连bug ,优化任务队列ing, 拆分,提升性能ing
1 parent e70771f commit 7b600d9

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

job-logger/job-logger-mongo/src/main/java/com/lts/job/biz/logger/mongo/MongoJobLogger.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.lts.job.biz.logger.mongo;
22

33

4+
import com.lts.job.biz.logger.JobLogUtils;
45
import com.lts.job.biz.logger.JobLogger;
56
import com.lts.job.biz.logger.domain.BizLogPo;
67
import com.lts.job.biz.logger.domain.JobLogPo;
@@ -18,14 +19,12 @@ public MongoJobLogger(Config config) {
1819

1920
@Override
2021
public void log(JobLogPo jobLogPo) {
21-
22-
23-
// ds.save(jobLogPo);
22+
template.save(jobLogPo);
2423
}
2524

2625
@Override
2726
public void log(BizLogPo bizLogPo) {
28-
// ds.save(JobLogUtils.bizConvert(bizLogPo));
27+
template.save(JobLogUtils.bizConvert(bizLogPo));
2928
}
3029

3130
}

0 commit comments

Comments
 (0)