From 558f36b3af483f4334e8c1eb158d829e6277c1a6 Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 13 Jun 2017 17:18:02 +0300 Subject: [PATCH] LocalCachedMapInvalidate object can't be serialized by Kryo codec. #918 --- .../main/java/org/redisson/RedissonLocalCachedMap.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java index 2d018a3c474..3f607a8457f 100644 --- a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java +++ b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java @@ -30,7 +30,6 @@ import java.util.Map; import java.util.NoSuchElementException; import java.util.Set; -import java.util.UUID; import java.util.concurrent.TimeUnit; import org.redisson.api.LocalCachedMapOptions; @@ -87,14 +86,14 @@ public static class LocalCachedMapClear implements Serializable { public static class LocalCachedMapInvalidate implements Serializable { private byte[] excludedId; - private List keyHashes; + private byte[][] keyHashes; public LocalCachedMapInvalidate() { } - public LocalCachedMapInvalidate(byte[] excludedId, byte[]... keyHash) { + public LocalCachedMapInvalidate(byte[] excludedId, byte[]... keyHashes) { super(); - this.keyHashes = Arrays.asList(keyHash); + this.keyHashes = keyHashes; this.excludedId = excludedId; } @@ -102,7 +101,7 @@ public byte[] getExcludedId() { return excludedId; } - public Collection getKeyHashes() { + public byte[][] getKeyHashes() { return keyHashes; }