| | |
| | | public void onApplicationEvent(OnlineEvent event) {
|
| | |
|
| | | if (logger.isDebugEnabled()) {
|
| | | logger.debug("设备离线事件触发,deviceId:" + event.getDeviceId() + ",from:" + event.getFrom());
|
| | | logger.debug("设备上线事件触发,deviceId:" + event.getDeviceId() + ",from:" + event.getFrom());
|
| | | }
|
| | |
|
| | | String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + event.getDeviceId();
|
| | |
| | | resultHolder.put(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid, result); |
| | | |
| | | if (streamInfo == null) { |
| | | // TODO playStreamCmd 超时处理 |
| | | // 发送点播消息 |
| | | cmder.playStreamCmd(device, channelId, (JSONObject response) -> { |
| | | logger.info("收到订阅消息: " + response.toJSONString()); |
| | | playService.onPublishHandlerForPlay(response, deviceId, channelId, uuid.toString()); |