前置联调
This commit is contained in:
@@ -3,9 +3,7 @@ package com.njcn.message.consumer;
|
|||||||
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import com.njcn.message.constant.MessageStatus;
|
import com.njcn.message.constant.MessageStatus;
|
||||||
import com.njcn.message.messagedto.DevComFlagDTO;
|
import com.njcn.message.messagedto.DevComFlagDTO;
|
||||||
import com.njcn.message.messagedto.MessageDataDTO;
|
import com.njcn.message.constant.RedisKeyPrefix;
|
||||||
import com.njcn.message.redis.RedisKeyPrefix;
|
|
||||||
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.AppRedisKey;
|
||||||
|
|||||||
Reference in New Issue
Block a user