Merge branch 'master' into dev/数据库统合2
commit
0ff4d04698
|
@ -199,7 +199,9 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (DocumentException e) {
|
} catch (DocumentException e) {
|
||||||
log.error("未处理的异常 ", e);
|
log.error("[收到移动位置订阅通知] 文档解析异常: \r\n{}", evt.getRequest(), e);
|
||||||
|
} catch ( Exception e) {
|
||||||
|
log.error("[收到移动位置订阅通知] 异常: ", e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -61,13 +61,7 @@ public class MobilePositionServiceImpl implements IMobilePositionService {
|
||||||
if (size == null || size == 0) {
|
if (size == null || size == 0) {
|
||||||
return new ArrayList<>();
|
return new ArrayList<>();
|
||||||
}
|
}
|
||||||
List<MobilePosition> mobilePositions;
|
return redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, Math.min(length, size));
|
||||||
if (size > length) {
|
|
||||||
mobilePositions = redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, length);
|
|
||||||
}else {
|
|
||||||
mobilePositions = redisTemplate.opsForList().rightPop(REDIS_MOBILE_POSITION_LIST, size);
|
|
||||||
}
|
|
||||||
return mobilePositions;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue