|
|
@ -67,7 +67,7 @@ public class ICWarnStatsEventListener implements MessageListenerConcurrently { |
|
|
|
lock = distributedLock.getLock(String.format("lock:ic_warn_stats:%s", obj.getCustomerId()), |
|
|
|
30L, 30L, TimeUnit.SECONDS); |
|
|
|
//待执行方法
|
|
|
|
SpringContextUtils.getBean(StatsResiWarnService.class).resiWarnByOne(obj.getCustomerId(), obj.getIcResiUser()); |
|
|
|
SpringContextUtils.getBean(StatsResiWarnService.class).resiWarn(obj.getCustomerId()); |
|
|
|
} catch (RenException e) { |
|
|
|
// 如果是我们手动抛出的异常,说明在业务可控范围内。目前不需要MQ重试
|
|
|
|
logger.error("【开放数据事件监听器】-客户居民信息变动MQ失败:".concat(ExceptionUtils.getErrorStackTrace(e))); |
|
|
|