Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改bug

Browse Source
This commit is contained in:
hzj
2025-03-13 10:23:22 +08:00
parent 7792dc5dfc
commit 8ebf6f3bbb
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
message/message-boot/src/main/java/com/njcn/message/consumer/RealTimeDataConsumer.java
View File

@@ -8,7 +8,6 @@ import com.njcn.message.redis.RedisKeyPrefix;
import com.njcn.message.websocket.WebSocketServer; import com.njcn.message.websocket.WebSocketServer;
import com.njcn.middle.rocket.constant.EnhanceMessageConstant; import com.njcn.middle.rocket.constant.EnhanceMessageConstant;
import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler; 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.pojo.enums.RedisKeyEnum;
import com.njcn.redis.utils.RedisUtil; import com.njcn.redis.utils.RedisUtil;
import com.njcn.system.api.RocketMqLogFeignClient; import com.njcn.system.api.RocketMqLogFeignClient;
@@ -84,7 +83,7 @@ public class RealTimeDataConsumer extends EnhanceConsumerMessageHandler<MessageD
String lineId = message.getMonitor(); String lineId = message.getMonitor();
WebSocketServer.sendInfo(JSONObject.toJSONString(message),lineId); WebSocketServer.sendInfo(JSONObject.toJSONString(message),lineId);
//删除推送的lineId //删除推送的lineId
redisUtil.delete("AskRealData:".concat(lineId)); redisUtil.delete(RedisKeyPrefix.ASK_REAL_DATA.concat(lineId));
} }