临时提交
This commit is contained in:
@@ -762,7 +762,7 @@ public class MediaServerServiceImpl implements IMediaServerService {
|
||||
calld = streamAuthorityInfo.getCallId();
|
||||
}
|
||||
List<StreamInfo> streamInfoList = getMediaList(mediaInfo, app, stream, calld);
|
||||
if (streamInfoList.isEmpty()) {
|
||||
if (streamInfoList == null || streamInfoList.isEmpty()) {
|
||||
return null;
|
||||
}else {
|
||||
return streamInfoList.get(0);
|
||||
|
||||
@@ -216,9 +216,10 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
|
||||
// 判断是否需要重启代理
|
||||
if (!streamProxyInDb.getApp().equals(streamProxy.getApp())
|
||||
|| !streamProxyInDb.getStream().equals(streamProxy.getStream())
|
||||
|| !streamProxyInDb.getMediaServerId().equals(streamProxy.getMediaServerId())
|
||||
|| (streamProxyInDb.getMediaServerId() != null && streamProxyInDb.getMediaServerId().equals(streamProxy.getMediaServerId()))
|
||||
|| (streamProxyInDb.getMediaServerId() == null && streamProxy.getMediaServerId() != null)
|
||||
) {
|
||||
// app/stream 变化则重启代理
|
||||
// 变化则重启代理
|
||||
stopProxy(streamProxyInDb);
|
||||
startProxy(streamProxy);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user