| | |
| | | sendNotify(parentPlatform, catalogXmlContent, subscribeInfo, eventResult -> { |
| | | logger.error("发送NOTIFY通知消息失败。错误:{} {}", eventResult.statusCode, eventResult.msg); |
| | | }, (eventResult -> { |
| | | logger.info("[发送NOTIFY通知]类型: {},发送成功: {}", type, channels.size()); |
| | | try { |
| | | sendNotifyForCatalogAddOrUpdate(type, parentPlatform, deviceChannels, subscribeInfo, |
| | | finalIndex + parentPlatform.getCatalogGroup()); |
| | |
| | | }else { |
| | | channels = deviceChannels.subList(index, deviceChannels.size()); |
| | | } |
| | | logger.info("[发送NOTIFY通知]类型: {},发送数量: {}", type, channels.size()); |
| | | Integer finalIndex = index; |
| | | String catalogXmlContent = getCatalogXmlContentForCatalogOther(parentPlatform, channels, type); |
| | | sendNotify(parentPlatform, catalogXmlContent, subscribeInfo, eventResult -> { |