|
@@ -547,6 +547,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
String sdpContent = createBroadcastInviteSdp(mediaServerItem,ssrcInfo);
|
|
|
String _ssrc = ssrcInfo.getSsrc();
|
|
|
// 使用 返回sdp ack 数据给设备
|
|
|
+ logger.info("recvStream {}", ssrcInfo.getStream());
|
|
|
logger.info("返回给设备的 audio invite sdp部分为{}",sdpContent);
|
|
|
try {
|
|
|
SIPResponse sipResponse = testInviteRequestProcessor.responseBroadcastSdpACK(request,
|
|
@@ -556,7 +557,8 @@ public class SIPCommander implements ISIPCommander {
|
|
|
sipConfig.getPort()
|
|
|
);
|
|
|
logger.info("[语音广播] 添加sip信息至流媒体服务中");
|
|
|
- streamSession.put(device.getDeviceId(),
|
|
|
+ streamSession.put(
|
|
|
+ device.getDeviceId(),
|
|
|
device.getDeviceId(),
|
|
|
"broadcast",
|
|
|
ssrcInfo.getStream(),
|
|
@@ -764,7 +766,12 @@ public class SIPCommander implements ISIPCommander {
|
|
|
logger.error("无法找到该设备信息");
|
|
|
return false;
|
|
|
}
|
|
|
- SsrcTransaction ssrcTransaction = streamSession.getSsrcTransaction(device.getDeviceId(),device.getDeviceId(), "broadcast", broadcastItem.getRecv_stream());
|
|
|
+ // 从流媒体服务器中关闭推流通道
|
|
|
+ SsrcTransaction ssrcTransaction = streamSession.getSsrcTransaction(
|
|
|
+ device.getDeviceId(),
|
|
|
+ device.getDeviceId(),
|
|
|
+ "broadcast",
|
|
|
+ broadcastItem.getRecv_stream());
|
|
|
logger.info("关闭语音广播: {}-{}",broadcastItem.getApp() , broadcastItem.getStream());
|
|
|
MediaServerItem mediaServerItem = mediaServerService.getOne(broadcastItem.getMediaId());
|
|
|
if(mediaServerItem == null){
|