From 18f37017b5f3fae3ba81ee4f6d039b73017089f3 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 8 Feb 2017 13:56:52 +0300 Subject: [PATCH] Fixed - RLocalCachedMap is not Redis cluster compatible --- redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java index ccff53f8b..d6755959d 100644 --- a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java +++ b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java @@ -216,7 +216,7 @@ public class RedissonLocalCachedMap extends RedissonMap implements R cache = new LFUCacheMap(options.getCacheSize(), options.getTimeToLiveInMillis(), options.getMaxIdleInMillis()); } - invalidationTopic = new RedissonTopic(commandExecutor, name + ":topic"); + invalidationTopic = new RedissonTopic(commandExecutor, suffixName(name, "topic")); if (options.isInvalidateEntryOnChange()) { invalidationListenerId = invalidationTopic.addListener(new MessageListener() { @Override