| | |
| | | import javax.sip.message.Response; |
| | | |
| | | /** |
| | | * @Description: 平台心跳超时事件 |
| | | * @description: 平台心跳超时事件 |
| | | * @author: panll |
| | | * @date: 2020年11月5日 10:00 |
| | | */ |
| | |
| | | storager.updateParentPlatformStatus(event.getPlatformGbID(), false); |
| | | publisher.platformNotRegisterEventPublish(event.getPlatformGbID()); |
| | | parentPlatformCatch.setKeepAliveReply(0); |
| | | redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch); |
| | | }else { |
| | | // 再次发送心跳 |
| | | String callId = sipCommanderForPlatform.keepalive(parentPlatform); |
| | |
| | | redisCatchStorage.updatePlatformKeepalive(parentPlatform); |
| | | redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch); |
| | | |
| | | sipSubscribe.addOkSubscribe(callId, (ResponseEvent responseEvent) ->{ |
| | | if (responseEvent.getResponse().getStatusCode() == Response.OK) { |
| | | sipSubscribe.addOkSubscribe(callId, (SipSubscribe.EventResult eventResult) ->{ |
| | | if (eventResult.statusCode == Response.OK) { |
| | | // 收到心跳响应信息, |
| | | parentPlatformCatch.setKeepAliveReply(0); |
| | | redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch); |