Parcourir la source

fix: 移除redis监听预期处理

hidewnd il y a 1 mois
Parent
commit
7e1df433a5

+ 2 - 3
yt-question/yt-question-service/src/main/java/com/ytpm/question/monitor/RedisKeyExpirationListener.java

@@ -47,9 +47,8 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
     @Override
     public void onMessage(Message message, byte[] pattern) {
         String key = String.valueOf(message);
-        log.info("App-Service 发现预定风控用户:{}", key);
-        if (!key.endsWith(applicationName)) {
-            return;
+        if (key.startsWith("lock_") || key.startsWith("unlock_")) {
+            log.info("App-Service 发现预定风控用户:{}", key);
         }
         // 用户锁定
         if (key.startsWith("lock_")) {