From d36ded1b3bedf5bc54e0a3557d1c4fcc2ff2ce91 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Thu, 6 Mar 2025 19:07:22 +0800 Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8=E5=8C=96?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=E7=BC=96=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/job/MessageProcessJob.java | 6 +++--- .../ai/analytic/center/mq/CommunityMessageConsumer.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java index a079214..f47086b 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java @@ -17,13 +17,13 @@ public class MessageProcessJob { /** * 邀约消息推送 */ - @XxlJob("processMessageByTask") + @XxlJob("communityMessageByTask") public ResultMsg processMessageByTask() { try { - log.info("processMessageByTask 开始执行定时任务补偿处理消息"); + log.info("communityMessageByTask 开始执行定时任务补偿处理消息"); mqMessageRecordService.processMessageByTask(); } catch (Exception e) { - log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage()); + log.error("communityMessageByTask 定时任务补偿处理消息异常",e.getMessage()); throw new RuntimeException(e); } return ResultMsg.ok(); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java index e590206..d60bd52 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java @@ -20,7 +20,7 @@ public class CommunityMessageConsumer implements RocketMQListener{ @Override public void onMessage(MessageExt messageExt) { - log.info("Received message: " + messageExt); + log.info("Received 社区舆情分析 message: " + messageExt); mqMessageRecordService.processMessageByMQ(new String(messageExt.getBody())); } }