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));
     }