Ver código fonte

添加异常处理

648540858 10 meses atrás
pai
commit
03033e6ac9

+ 3 - 1
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForMobilePositionProcessor.java

@@ -199,7 +199,9 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 					}
 				}
 			} catch (DocumentException e) {
-				log.error("未处理的异常 ", e);
+				log.error("[收到移动位置订阅通知] 文档解析异常: \r\n{}", evt.getRequest(), e);
+			} catch ( Exception e) {
+				log.error("[收到移动位置订阅通知] 异常: ", e);
 			}
 		}
 	}

+ 1 - 7
src/main/java/com/genersoft/iot/vmp/service/impl/MobilePositionServiceImpl.java

@@ -61,13 +61,7 @@ public class MobilePositionServiceImpl implements IMobilePositionService {
         if (size == null || size == 0) {
             return new ArrayList<>();
         }
-        List<MobilePosition> mobilePositions;
-        if (size > length) {
-            mobilePositions = redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, length);
-        }else {
-            mobilePositions = redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, size);
-        }
-        return  mobilePositions;
+        return redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, Math.min(length, size));
     }