diff --git a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java index 79054717c..39e125c9b 100644 --- a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java +++ b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java @@ -339,7 +339,7 @@ public class RedissonLocalCachedMap extends RedissonMap implements R } byte[] encodedKey = encodeMapKey(key); - byte[] encodedValue = encodeMapKey(value); + byte[] encodedValue = encodeMapValue(value); CacheKey cacheKey = toCacheKey(encodedKey); byte[] msg = encode(new LocalCachedMapInvalidate(instanceId, cacheKey.getKeyHash())); CacheValue cacheValue = new CacheValue(key, value);