This commit is contained in:
zxb 2024-03-17 17:11:58 +08:00
parent 5e982bfb02
commit e7339a5f78

View File

@ -201,12 +201,14 @@ public class AckRequestProcessor extends SIPRequestProcessorParent implements In
if(resp != null){ if(resp != null){
if(resp.getInteger("code") != 0){ if(resp.getInteger("code") != 0){
String msg = resp.getString("msg"); String msg = resp.getString("msg");
if (!msg.equalsIgnoreCase(failMag.get()) && !StringUtils.containsIgnoreCase(msg,"can not find the source stream")) { if (!msg.equalsIgnoreCase(failMag.get())){
failMag.set(msg); failMag.set(msg);
if (!StringUtils.containsIgnoreCase(msg, "can not find the source stream")) {
logger.debug("rtp转推失败 {} {}, {}, {}", msg, channelId, mediaInfo, param); logger.debug("rtp转推失败 {} {}, {}, {}", msg, channelId, mediaInfo, param);
} }
} }
} }
}
return resp == null || resp.getInteger("code") != 0; return resp == null || resp.getInteger("code") != 0;
}) })
.retryIfException() .retryIfException()