根据redis消息更新推流列表

jiang

2022-08-18 8f77d0c25cdd37d4cc96c923b46ae28607bae51d

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java

@@ -26,8 +26,8 @@
@Component
public class RegisterResponseProcessor extends SIPResponseProcessorAbstract {

   private Logger logger = LoggerFactory.getLogger(RegisterResponseProcessor.class);
   private String method = "REGISTER";
   private final Logger logger = LoggerFactory.getLogger(RegisterResponseProcessor.class);
   private final String method = "REGISTER";

   @Autowired
   private ISIPCommanderForPlatform sipCommanderForPlatform;
@@ -69,11 +69,11 @@

      ParentPlatformCatch parentPlatformCatch = redisCatchStorage.queryPlatformCatchInfo(platformGBId);
      if (parentPlatformCatch == null) {
         logger.warn(String.format("收到 %s 的注册/注销%S请求, 但是平台缓存信息未查询到!!!", platformGBId, response.getStatusCode()));
         logger.warn(String.format("[收到注册/注销%S请求]平台：%s，但是平台缓存信息未查询到!!!", response.getStatusCode(),platformGBId));
         return;
      }
      String action = parentPlatformCatch.getParentPlatform().getExpires().equals("0") ? "注销" : "注册";
      logger.info(String.format("收到 %s %s的%S响应", platformGBId, action, response.getStatusCode() ));
      logger.info(String.format("[%s %S响应]%s ", action, response.getStatusCode(), platformGBId ));
      ParentPlatform parentPlatform = parentPlatformCatch.getParentPlatform();
      if (parentPlatform == null) {
         logger.warn(String.format("收到 %s %s的%S请求, 但是平台信息未查询到!!!", platformGBId, action, response.getStatusCode()));