添加被动消息重试机制

segment2.0
beeajax 2 years ago
parent 798ab2be7e
commit 72f48f7c5c

@ -2,7 +2,7 @@ package com.docus.server.collect.report.service.impl;
import com.docus.core.util.Func;
import com.docus.infrastructure.redis.service.IdService;
import com.docus.log.annotation.TrackRetry;
import com.docus.log.annotation.TrackRetryListener;
import com.docus.server.archivefile.mapper.AfCollectTaskMapper;
import com.docus.server.archivefile.mapper.AfReportRecordMapper;
import com.docus.server.archivefile.pojo.dto.ReportDTO;
@ -41,7 +41,7 @@ public class ReportServiceImpl implements IReportService {
private IdService idService;
@Override
@TrackRetry("report")
@TrackRetryListener("report")
public void report(ReportDTO reportDTO) {
// 系统无视图生成的任务,消费查询的报告
if (reportDTO.getTaskId() != null) {

Loading…
Cancel
Save