From 0e59e18ea23ed1d98a4d9c539e1155b4230cca1c Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Wed, 14 May 2025 13:59:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=89=8D=E7=BD=AE=E8=81=94=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/njcn/message/consumer/FrontDataConsumer.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumer.java b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumer.java index b1c22f8..9cb4278 100644 --- a/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumer.java +++ b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumer.java @@ -1,10 +1,12 @@ package com.njcn.message.consumer; -import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.JSONObject; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; import com.njcn.message.constant.MessageStatus; import com.njcn.message.messagedto.MessageDataDTO; -import com.njcn.message.redis.RedisKeyPrefix; +import com.njcn.message.constant.RedisKeyPrefix; import com.njcn.middle.rocket.constant.EnhanceMessageConstant; import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler; import com.njcn.redis.pojo.enums.RedisKeyEnum; @@ -24,6 +26,9 @@ import javax.annotation.Resource; import java.util.ArrayList; import java.util.List; import java.util.Objects; +import java.util.concurrent.Executors; +import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; /** @@ -158,8 +163,6 @@ public class FrontDataConsumer extends EnhanceConsumerMessageHandler