retry机制抛出异常
This commit is contained in:
@@ -199,7 +199,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
|
|||||||
data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
|
data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
|
||||||
data.put("aiAnalysisRequestId", aiAnalysisRequestId);
|
data.put("aiAnalysisRequestId", aiAnalysisRequestId);
|
||||||
data.put("fileType", claimVerificationFileAnalysisDTO.getFileType());
|
data.put("fileType", claimVerificationFileAnalysisDTO.getFileType());
|
||||||
log.info("索赔检核发送异常空MQMQ: {}", data.toString());
|
log.info("索赔检核发送异常空MQ: {}", data.toString());
|
||||||
rocketMQTemplate.syncSend(topic, data);
|
rocketMQTemplate.syncSend(topic, data);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ public class DiFyRetryImpl {
|
|||||||
private DiFyService diFyService;
|
private DiFyService diFyService;
|
||||||
@Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000))
|
@Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000))
|
||||||
public JSONObject getDiFyRetry(DiFyReq diFyReq) {
|
public JSONObject getDiFyRetry(DiFyReq diFyReq) {
|
||||||
log.info("diFyService class: {}", diFyService.getClass());
|
log.info("AI索赔检核调用DIFY(retry)");
|
||||||
return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq);
|
return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user