Refactoring

redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java

@@ -415,24 +415,6 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
     }
 
     
-    @Override
-    public void putAll(Map<? extends K, ? extends V> m) {
-        Map<CacheKey, CacheValue> cacheMap = new HashMap<CacheKey, CacheValue>(m.size());
-        for (java.util.Map.Entry<? extends K, ? extends V> entry : m.entrySet()) {
-            CacheKey cacheKey = toCacheKey(entry.getKey());
-            CacheValue cacheValue = new CacheValue(entry.getKey(), entry.getValue());
-            cacheMap.put(cacheKey, cacheValue);
-        }
-        cache.putAll(cacheMap);
-        super.putAll(m);
-        
-        if (invalidateEntryOnChange == 1) {
-            for (CacheKey cacheKey : cacheMap.keySet()) {
-                invalidationTopic.publish(new LocalCachedMapInvalidate(instanceId, cacheKey.getKeyHash()));
-            }
-        }
-    }
-
     @Override
     public RFuture<Boolean> deleteAsync() {
         cache.clear();
@@ -754,6 +736,7 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
         }
         params.addAll(msgs);
 
+        final RPromise<Void> result = newPromise();
         RFuture<Void> future = commandExecutor.evalWriteAsync(getName(), codec, RedisCommands.EVAL_VOID,
                 "redis.call('hmset', KEYS[1], unpack(ARGV, 3, tonumber(ARGV[2]) + 2));"
               + "if ARGV[1] == '1' then "
@@ -771,9 +754,10 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
                 }
                 
                 cacheMap(map);
+                result.trySuccess(null);
             }
         });
-        return future;
+        return result;
     }
 
     @Override

redisson/src/test/java/org/redisson/RedissonLocalCachedMapTest.java

@@ -323,7 +323,7 @@ public class RedissonLocalCachedMapTest extends BaseTest {
     }
 
     @Test
-    public void testPutAll() {
+    public void testPutAll() throws InterruptedException {
         Map<Integer, String> map = redisson.getLocalCachedMap("simple", LocalCachedMapOptions.defaults());
         Map<Integer, String> map1 = redisson.getLocalCachedMap("simple", LocalCachedMapOptions.defaults());
         Cache<CacheKey, CacheValue> cache = Deencapsulation.getField(map, "cache");
@@ -344,6 +344,9 @@ public class RedissonLocalCachedMapTest extends BaseTest {
         
         map1.putAll(joinMap);
         
+        // waiting for cache cleanup listeners triggering 
+        Thread.sleep(500);
+        
         assertThat(cache.size()).isEqualTo(3);
         assertThat(cache1.size()).isEqualTo(3);
     }