|
|
@@ -9,6 +9,7 @@ import com.inspur.netty.domain.MediaServerConstants;
|
|
|
import com.inspur.netty.domain.vo.StartStreamResultVo;
|
|
|
import com.inspur.netty.message.push.PushMessageType;
|
|
|
import com.inspur.netty.stream.service.IStreamService;
|
|
|
+import com.inspur.netty.util.NettyConstants;
|
|
|
import com.inspur.netty.util.PushMsgUtil;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import org.dromara.common.core.utils.StringUtils;
|
|
|
@@ -62,7 +63,7 @@ public class StreamServiceImpl implements IStreamService {
|
|
|
String taskParam = PushMessageType.CONTROL_START_STREAM.getValue();
|
|
|
smsbDeviceTaskService.createNewDeviceTask(DeviceTaskConstants.DEVICE_TASK_STREAM_START, smsbDeviceVo, taskParam);
|
|
|
// 5 发送netty消息,通知设备开始推流
|
|
|
- String nettyMessage = PushMessageType.CONTROL_START_STREAM.getValue() + "|" + streamUrl;
|
|
|
+ String nettyMessage = PushMessageType.CONTROL_START_STREAM.getValue() + "|" + streamUrl + NettyConstants.DATA_PACK_SEPARATOR;
|
|
|
boolean pushResult = PushMsgUtil.sendV2(smsbDeviceVo.getIdentifier(), nettyMessage);
|
|
|
resultVo.setPushResult(pushResult);
|
|
|
resultVo.setViewUrl(viewUrl);
|