handle resp3 messages

redis · Aug 26, 2023 · e7de9fd · e7de9fd
1 parent 88ae7e2
commit e7de9fd
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/src/main/java/redis/clients/jedis/JedisPubSubBase.java b/src/main/java/redis/clients/jedis/JedisPubSubBase.java
@@ -11,6 +11,7 @@
 
 public abstract class JedisPubSubBase<T> {
 
+  private static final byte[] INVALIDATE_CHANNEL = SafeEncoder.encode("__redis__:invalidate");
   private int subscribedChannels = 0;
   private volatile Connection client;
 
@@ -163,6 +164,14 @@ private void process() {
           final byte[] bpattern = (byte[]) listReply.get(1);
           final T enpattern = (bpattern == null) ? null : encode(bpattern);
           onPong(enpattern);
+        } else if (Arrays.equals(INVALIDATE.getRaw(), resp)) {
+          final T enchannel = encode(INVALIDATE_CHANNEL);
+          final List<byte[]> bkeys = (List<byte[]>) listReply.get(1);
+          if (bkeys == null) {
+            onMessage(enchannel, null);
+          } else {
+            bkeys.stream().map(this::encode).forEach(msg -> onMessage(enchannel, msg));
+          }
         } else {
           throw new JedisException("Unknown message type: " + firstObj);
         }

diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java
@@ -338,7 +338,7 @@ public byte[] getRaw() {
   public static enum ResponseKeyword implements Rawable {
 
     SUBSCRIBE, PSUBSCRIBE, UNSUBSCRIBE, PUNSUBSCRIBE, MESSAGE, PMESSAGE, PONG,
-    SSUBSCRIBE, SUNSUBSCRIBE, SMESSAGE;
+    SSUBSCRIBE, SUNSUBSCRIBE, SMESSAGE, INVALIDATE;
 
     private final byte[] raw;