From 2f7deb7a2fb33002372559f3b86eb707a035f694 Mon Sep 17 00:00:00 2001 From: jianjun Date: Mon, 26 Apr 2021 15:16:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BB=B6=E8=BF=9F=E6=B6=88=E8=B4=B9=20todo=20?= =?UTF-8?q?=E4=BD=BF=E7=94=A8=E5=BB=B6=E8=BF=9F=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/epmet/mq/type1/GroupAchievementCustomListener.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java index 5410794265..af9624d5ca 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java @@ -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) {