| | |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; |
|---|
| | | import com.genersoft.iot.vmp.service.IMediaServerService; |
|---|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorage; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(PlatformNotRegisterEventLister.class); |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IVideoManagerStorager storager; |
|---|
| | | private IVideoManagerStorage storager; |
|---|
| | | @Autowired |
|---|
| | | private IRedisCatchStorage redisCatchStorage; |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | stream.append(","); |
|---|
| | | } |
|---|
| | | stream.append(sendRtpItem.getStreamId()); |
|---|
| | | redisCatchStorage.deleteSendRTPServer(event.getPlatformGbID(), sendRtpItem.getChannelId()); |
|---|
| | | redisCatchStorage.deleteSendRTPServer(event.getPlatformGbID(), sendRtpItem.getChannelId(), null, null); |
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | Map<String, Object> param = new HashMap<>(); |
|---|
| | | param.put("vhost", "__defaultVhost__"); |
|---|
| | |
|---|
| | | zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | Timer timer = new Timer(); |
|---|
| | | SipSubscribe.Event okEvent = (responseEvent)->{ |
|---|
| | | timer.cancel(); |
|---|
