diff --git a/redisson/src/main/java/org/redisson/RedissonMap.java b/redisson/src/main/java/org/redisson/RedissonMap.java index 4188271e92727eb4e704f2045c971728aa71c42d..581a53333a7bf76966606ba9aeae5bf94493d7ec 100644 --- a/redisson/src/main/java/org/redisson/RedissonMap.java +++ b/redisson/src/main/java/org/redisson/RedissonMap.java @@ -1200,6 +1200,10 @@ public class RedissonMap extends RedissonExpirable implements RMap { @Override public RFuture loadAllAsync(boolean replaceExistingValues, int parallelism) { + if (options.getLoader() == null) { + throw new NullPointerException("MapLoader isn't defined"); + } + Iterable keys; try { keys = options.getLoader().loadAllKeys(); @@ -1217,10 +1221,14 @@ public class RedissonMap extends RedissonExpirable implements RMap { @Override public RFuture loadAllAsync(Set keys, boolean replaceExistingValues, int parallelism) { - return loadAllAsync((Iterable) keys, replaceExistingValues, parallelism, null); + return loadAllAsync(keys, replaceExistingValues, parallelism, null); } protected RFuture loadAllAsync(Iterable keys, boolean replaceExistingValues, int parallelism, Map loadedEntires) { + if (options.getLoader() == null) { + throw new NullPointerException("MapLoader isn't defined"); + } + if (parallelism < 1) { throw new IllegalArgumentException("parallelism can't be lower than 1"); }