From 8c1c003c60d2f27b3c55e248451caeec7f2b5631 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 28 一月 2021 19:06:28 +0800 Subject: [PATCH] 活动管理界面完善 --- service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/ActivityDrawnNotifyConsumer.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) diff --git a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/ActivityDrawnNotifyConsumer.java b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/ActivityDrawnNotifyConsumer.java index b8614c5..e6a6221 100644 --- a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/ActivityDrawnNotifyConsumer.java +++ b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/ActivityDrawnNotifyConsumer.java @@ -3,6 +3,7 @@ import com.ks.daylucky.exception.ActivityDrawnRecieveNotifyInfoException; import com.ks.daylucky.pojo.DO.ActivityDrawnRecieveNotifyInfo; import com.ks.daylucky.service.ActivityDrawnRecieveNotifyInfoService; +import com.ks.daylucky.util.LoggerUtil; import com.ks.daylucky.util.mq.CMQManager; import com.ks.lucky.pojo.DO.LuckyActivityAwardResult; import com.ks.lucky.pojo.DO.LuckyActivityAwards; @@ -40,7 +41,7 @@ new JobThreadExecutorServiceImpl().run(new Runnable() { @Override public void run() { - logger.info("鎺ユ敹娑堟伅"); + LoggerUtil.mqLogger.info("鎺ユ敹娑堟伅 {}", ActivityDrawnNotifyConsumer.class.getSimpleName()); List<Message> messageList = CMQManager.getInstance().consumeActivityDrawnMsg(16); if (messageList != null) { for (Message message : messageList) { -- Gitblit v1.8.0