| | |
| | | }
|
| | | GbStream gbStream = storager.getGbStream(param.getApp(), param.getStream());
|
| | | if (gbStream != null) {
|
| | | eventPublisher.catalogEventPublishForStream(null, gbStream, param.isRegist()?CatalogEvent.ON:CatalogEvent.OFF);
|
| | | if (userSetting.isUsePushingAsStatus()) {
|
| | | eventPublisher.catalogEventPublishForStream(null, gbStream, param.isRegist()?CatalogEvent.ON:CatalogEvent.OFF);
|
| | | }
|
| | | }
|
| | | if (type != null) {
|
| | | // 发送流变化redis消息
|
| | |
| | | // 拉流代理
|
| | | StreamProxyItem streamProxyItem = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream());
|
| | | if (streamProxyItem != null) {
|
| | | if (streamProxyItem.isEnableDisableNoneReader()) {
|
| | | if (streamProxyItem.isEnableRemoveNoneReader()) {
|
| | | // 无人观看自动移除
|
| | | ret.put("close", true);
|
| | | streamProxyService.del(param.getApp(), param.getStream());
|