|
|
@ -58,6 +58,12 @@ public class GroupAchievementCustomListener implements MessageListenerConcurrent |
|
|
|
logger.error("consumer fail,msg:{}",msgObj); |
|
|
|
return; |
|
|
|
} |
|
|
|
//消息被消费太快 业务数据还没有完成 歇一会先
|
|
|
|
try { |
|
|
|
Thread.sleep(200L); |
|
|
|
} catch (InterruptedException e) { |
|
|
|
logger.error("consumeMessage sleep",e); |
|
|
|
} |
|
|
|
Boolean aBoolean = SpringContextUtils.getBean(StatsAchievementService.class).calculateAcm(msgObj.getCustomerId(), msgObj.getGroupId(), msgObj.getAchievementType()); |
|
|
|
logger.info("consumer msg success,{}",aBoolean); |
|
|
|
} catch (RenException e) { |
|
|
|