diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderForPlatform.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderForPlatform.java index 4159c8ca7..037d9332e 100755 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderForPlatform.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderForPlatform.java @@ -243,7 +243,7 @@ public class SIPCommanderForPlatform implements ISIPCommanderForPlatform { if (sendAfterResponse) { // 默认按照收到200回复后发送下一条, 如果超时收不到回复,就以30毫秒的间隔直接发送。 sipSender.transmitRequest(parentPlatform.getDeviceIp(), request, eventResult -> { - if (eventResult.type.equals(SipSubscribe.EventResultType.timeout)) { + if (eventResult.statusCode == -1024) { // 消息发送超时, 以30毫秒的间隔直接发送 int indexNext = index + parentPlatform.getCatalogGroup(); try { @@ -266,8 +266,7 @@ public class SIPCommanderForPlatform implements ISIPCommanderForPlatform { }); }else { sipSender.transmitRequest(parentPlatform.getDeviceIp(), request, eventResult -> { - log.error("[目录推送失败] 国标级联 platform : {}, code: {}, msg: {}, 停止发送", parentPlatform.getServerGBId(), eventResult.statusCode, eventResult.msg); - dynamicTask.stop(timeoutTaskKey); + log.error("[目录推送失败] 国标级联 platform : {}, code: {}, msg: {}", parentPlatform.getServerGBId(), eventResult.statusCode, eventResult.msg); }, null); dynamicTask.startDelay(timeoutTaskKey, ()->{ int indexNext = index + parentPlatform.getCatalogGroup();