添加被动消息重试机制

segment2.0
beeajax 2 years ago
parent 72f48f7c5c
commit b2c2c75c60

@ -174,7 +174,7 @@ mybatis-plus:
field-strategy: NOT_EMPTY field-strategy: NOT_EMPTY
db-type: MYSQL db-type: MYSQL
mapper-locations: classpath*:/mapper/*Mapper.xml,file:mybatis.mapper/**/*Mapper.xml mapper-locations: classpath*:/mapper/*Mapper.xml,file:mybatis.mapper/**/*Mapper.xml
typeEnumsPackage: com.docus.server.collect.web.enums,com.docus.server.common.enums type-enums-package: com.docus.server.collect.web.enums,com.docus.server.common.enums
xxl: xxl:
job: job:

@ -69,7 +69,7 @@ public class VisitorProcessor extends AbstractProcessor {
return result.ok(params); return result.ok(params);
} else { } else {
log.info("=== AOP 异常通知 ==="); log.info("=== AOP 异常通知 ===");
log.error((String) params.get(context.getExMessageResult())); log.error((String) params.get("msg"));
messageService.updateTaskOriginalMessage(taskId, afterReturnResult, context.getExMessageResult(), StateEnum.FAIL); messageService.updateTaskOriginalMessage(taskId, afterReturnResult, context.getExMessageResult(), StateEnum.FAIL);
return result.fail(params); return result.fail(params);
} }

Loading…
Cancel
Save