From 8ebf6f3bbb714c2a8c7dc3de0bacd1b16b28e756 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Thu, 13 Mar 2025 10:23:22 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/njcn/message/consumer/RealTimeDataConsumer.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/message/message-boot/src/main/java/com/njcn/message/consumer/RealTimeDataConsumer.java b/message/message-boot/src/main/java/com/njcn/message/consumer/RealTimeDataConsumer.java
index a665173..afddb15 100644
--- a/message/message-boot/src/main/java/com/njcn/message/consumer/RealTimeDataConsumer.java
+++ b/message/message-boot/src/main/java/com/njcn/message/consumer/RealTimeDataConsumer.java
@@ -8,7 +8,6 @@ import com.njcn.message.redis.RedisKeyPrefix;
 import com.njcn.message.websocket.WebSocketServer;
 import com.njcn.middle.rocket.constant.EnhanceMessageConstant;
 import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler;
-import com.njcn.redis.pojo.enums.AppRedisKey;
 import com.njcn.redis.pojo.enums.RedisKeyEnum;
 import com.njcn.redis.utils.RedisUtil;
 import com.njcn.system.api.RocketMqLogFeignClient;
@@ -84,7 +83,7 @@ public class RealTimeDataConsumer extends EnhanceConsumerMessageHandler<MessageD
         String lineId = message.getMonitor();
         WebSocketServer.sendInfo(JSONObject.toJSONString(message),lineId);
         //删除推送的lineId
-        redisUtil.delete("AskRealData:".concat(lineId));
+        redisUtil.delete(RedisKeyPrefix.ASK_REAL_DATA.concat(lineId));
     }