| | |
|---|
| | | |
|---|
| | | private boolean taskQueueHandlerRun = false; |
|---|
| | | |
|---|
| | | private final ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | |
|---|
| | | @Qualifier("taskExecutor") |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | JSONObject msgJSON = JSON.parseObject(msg.getBody(), JSONObject.class); |
|---|
| | | WvpRedisMsg wvpRedisMsg = JSON.toJavaObject(msgJSON, WvpRedisMsg.class); |
|---|
| | | if (!userSetting.getServerId().equals(wvpRedisMsg.getToId())) { |
|---|
| | | return; |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (WvpRedisMsg.isRequest(wvpRedisMsg)) { |
|---|
| | | logger.info("[收到REDIS通知] 请求： {}", new String(msg.getBody())); |
|---|
