| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONArray; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.baomidou.dynamic.datasource.annotation.DS; |
|---|
| | | import com.genersoft.iot.vmp.common.GeneralCallback; |
|---|
| | | import com.genersoft.iot.vmp.common.StreamInfo; |
|---|
| | | import com.genersoft.iot.vmp.conf.DynamicTask; |
|---|
| | |
|---|
| | | * 视频代理业务 |
|---|
| | | */ |
|---|
| | | @Service |
|---|
| | | @DS("master") |
|---|
| | | public class StreamProxyServiceImpl implements IStreamProxyService { |
|---|
| | | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(StreamProxyServiceImpl.class); |
|---|
| | |
|---|
| | | streamProxyMapper.deleteAutoRemoveItemByMediaServerId(mediaServerId); |
|---|
| | | |
|---|
| | | // 移除拉流代理生成的流信息 |
|---|
| | | // syncPullStream(mediaServerId); |
|---|
| | | syncPullStream(mediaServerId); |
|---|
| | | |
|---|
| | | // 恢复流代理, 只查找这个这个流媒体 |
|---|
| | | List<StreamProxyItem> streamProxyListForEnable = storager.getStreamProxyListForEnableInMediaServer( |
|---|
