| | |
|---|
| | | if (autoApplyPlay) {
|
|---|
| | | String app = json.getString("app");
|
|---|
| | | String streamId = json.getString("stream");
|
|---|
| | | if ("rtp".equals(app) && streamId.indexOf("gb_play") > -1) {
|
|---|
| | | StreamInfo streamInfo = storager.queryPlayByStreamId(streamId);
|
|---|
| | | if ("rtp".equals(app) && streamId.indexOf("gb_play") > -1 && streamInfo == null) {
|
|---|
| | | String[] s = streamId.split("_");
|
|---|
| | | if (s.length == 4) {
|
|---|
| | | String deviceId = s[2];
|
|---|
| | |
|---|
| | | cmder.playStreamCmd(device, channelId, (JSONObject response) -> {
|
|---|
| | | logger.info("收到订阅消息： " + response.toJSONString());
|
|---|
| | | playService.onPublishHandlerForPlay(response, deviceId, channelId, uuid.toString());
|
|---|
| | | });
|
|---|
| | | }, null);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
