diff --git a/redisson/src/main/java/org/redisson/api/MapOptions.java b/redisson/src/main/java/org/redisson/api/MapOptions.java index e00a3bc36..f0a4b272a 100644 --- a/redisson/src/main/java/org/redisson/api/MapOptions.java +++ b/redisson/src/main/java/org/redisson/api/MapOptions.java @@ -96,7 +96,9 @@ public class MapOptions { * @return MapOptions instance */ public MapOptions writer(MapWriter writer) { - this.writer = new RetryableMapWriter<>(this, writer); + if (writer != null) { + this.writer = new RetryableMapWriter<>(this, writer); + } return this; } public MapWriter getWriter() { @@ -110,7 +112,9 @@ public class MapOptions { * @return MapOptions instance */ public MapOptions writerAsync(MapWriterAsync writer) { - this.writerAsync = new RetryableMapWriterAsync<>(this, writer); + if (writer != null) { + this.writerAsync = new RetryableMapWriterAsync<>(this, writer); + } return this; } public MapWriterAsync getWriterAsync() {