增加同步通道超时时间,修复hookIP空字符串时的hookIP的默认值赋值
parent
377f0f2c82
commit
ecb5b69101
|
@ -14,6 +14,9 @@ public class MediaConfig {
|
||||||
@Value("${media.hookIp:${sip.ip}}")
|
@Value("${media.hookIp:${sip.ip}}")
|
||||||
private String hookIp;
|
private String hookIp;
|
||||||
|
|
||||||
|
@Value("${sip.ip}")
|
||||||
|
private String sipIp;
|
||||||
|
|
||||||
@Value("${media.sdpIp:${media.ip}}")
|
@Value("${media.sdpIp:${media.ip}}")
|
||||||
private String sdpIp;
|
private String sdpIp;
|
||||||
|
|
||||||
|
@ -68,7 +71,12 @@ public class MediaConfig {
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getHookIp() {
|
public String getHookIp() {
|
||||||
return hookIp;
|
if (StringUtils.isEmpty(hookIp)){
|
||||||
|
return sipIp;
|
||||||
|
}else {
|
||||||
|
return hookIp;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setHookIp(String hookIp) {
|
public void setHookIp(String hookIp) {
|
||||||
|
@ -76,7 +84,11 @@ public class MediaConfig {
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getSdpIp() {
|
public String getSdpIp() {
|
||||||
return sdpIp;
|
if (StringUtils.isEmpty(sdpIp)){
|
||||||
|
return ip;
|
||||||
|
}else {
|
||||||
|
return sdpIp;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setSdpIp(String sdpIp) {
|
public void setSdpIp(String sdpIp) {
|
||||||
|
@ -84,7 +96,11 @@ public class MediaConfig {
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getStreamIp() {
|
public String getStreamIp() {
|
||||||
return streamIp;
|
if (StringUtils.isEmpty(streamIp)){
|
||||||
|
return ip;
|
||||||
|
}else {
|
||||||
|
return streamIp;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setStreamIp(String streamIp) {
|
public void setStreamIp(String streamIp) {
|
||||||
|
|
|
@ -149,7 +149,7 @@ public class DeviceQuery {
|
||||||
msg.setData(String.format("同步通道失败,错误码: %s, %s", response.getStatusCode(), response.getReasonPhrase()));
|
msg.setData(String.format("同步通道失败,错误码: %s, %s", response.getStatusCode(), response.getReasonPhrase()));
|
||||||
resultHolder.invokeResult(msg);
|
resultHolder.invokeResult(msg);
|
||||||
});
|
});
|
||||||
DeferredResult<ResponseEntity<Device>> result = new DeferredResult<ResponseEntity<Device>>(2*1000L);
|
DeferredResult<ResponseEntity<Device>> result = new DeferredResult<ResponseEntity<Device>>(15*1000L);
|
||||||
result.onTimeout(()->{
|
result.onTimeout(()->{
|
||||||
logger.warn(String.format("设备通道信息同步超时"));
|
logger.warn(String.format("设备通道信息同步超时"));
|
||||||
// 释放rtpserver
|
// 释放rtpserver
|
||||||
|
|
Loading…
Reference in New Issue