From d7373ee97dd7679ef899104f6df09d6d6ec82cf0 Mon Sep 17 00:00:00 2001 From: jianjun Date: Thu, 6 May 2021 15:34:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=BC=BA=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/mq/ProjectChangedCustomListener.java | 5 ++--- .../java/com/epmet/mq/GroupAchievementCustomListener.java | 6 +++--- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java index 51fa695a51..ecc2d38a9b 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java @@ -56,12 +56,11 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently private void consumeMessage(String msg) { logger.info("receive customerId:{}", JSON.toJSONString(msg)); - if (StringUtils.isBlank(msg)){ + ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class); + if (msgObj == null){ log.warn("consumeMessage msg body is blank"); return; } - ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class); - DistributedLock distributedLock = null; RLock lock = null; try { diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java index e389d5044e..33c0ff7c63 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java @@ -48,12 +48,12 @@ public class GroupAchievementCustomListener implements MessageListenerConcurren private void consumeMessage(MessageExt messageExt) { logger.info("receive msg:{}", JSON.toJSONString(messageExt)); String msg = new String(messageExt.getBody()); - if (StringUtils.isBlank(msg)){ + + GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class); + if (msgObj == null){ log.warn("consumeMessage msg body is blank"); return; } - GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class); - DistributedLock distributedLock = null; RLock lock = null;