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<MessageExt>{
 
     @Override
     public void onMessage(MessageExt messageExt) {
-        log.info("Received message: " + messageExt);
+        log.info("Received 社区舆情分析 message: " + messageExt);
         mqMessageRecordService.processMessageByMQ(new String(messageExt.getBody()));
     }
 }