Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善重试日志

Browse Source
This commit is contained in:
shikong 2023-09-09 23:13:12 +08:00
parent 707c38da72
commit c7d79b48ab
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java
View File

@ -127,11 +127,18 @@ public class WvpService {
try { try {
genericRetryer.call(() -> video(asyncResponse, deviceCode, deviceId, channelId, startTime, endTime)); genericRetryer.call(() -> video(asyncResponse, deviceCode, deviceId, channelId, startTime, endTime));
} catch (RetryException e) { } catch (RetryException e) {
String reason = MessageFormat.format("调用 wvp api 查询设备历史失败, 已重试 {0} 次", e.getNumberOfFailedAttempts()); Attempt<?> failedAttempt = e.getLastFailedAttempt();
String reason;
if(failedAttempt.hasException()){
reason = MessageFormat.format("调用 wvp api 查询设备: {0} 历史失败, 已重试 {1} 次, 异常: {2}", deviceCode, e.getNumberOfFailedAttempts(), failedAttempt.getExceptionCause().getMessage());
} else {
reason = MessageFormat.format("调用 wvp api 查询设备: {0} 历史失败, 已重试 {1} 次", deviceCode, e.getNumberOfFailedAttempts());
}
log.error(reason); log.error(reason);
writeErrorToResponse(asyncResponse, JsonResponse.error(reason)); writeErrorToResponse(asyncResponse, JsonResponse.error(reason));
} catch (Exception e) { } catch (Exception e) {
writeErrorToResponse(asyncResponse, JsonResponse.error(e.getMessage())); String reason = MessageFormat.format("调用 wvp api 查询设备: {0} 历史失败, 异常: {2}", deviceCode, e.getMessage());
writeErrorToResponse(asyncResponse, JsonResponse.error(reason));
} finally { } finally {
asyncContext.complete(); asyncContext.complete();
} }