diff --git a/src/main/java/org/redisson/RedissonMap.java b/src/main/java/org/redisson/RedissonMap.java index c127a7842..91e8c2ee4 100644 --- a/src/main/java/org/redisson/RedissonMap.java +++ b/src/main/java/org/redisson/RedissonMap.java @@ -285,8 +285,8 @@ public class RedissonMap extends RedissonExpirable implements RMap { } } else { connection.unwatch(); + return null; } - return null; } } }); diff --git a/src/test/java/org/redisson/RedissonConcurrentMapTest.java b/src/test/java/org/redisson/RedissonConcurrentMapTest.java index cd2c33388..be96a8163 100644 --- a/src/test/java/org/redisson/RedissonConcurrentMapTest.java +++ b/src/test/java/org/redisson/RedissonConcurrentMapTest.java @@ -84,7 +84,7 @@ public class RedissonConcurrentMapTest extends BaseConcurrentTest { @Override public void run(Redisson redisson) { ConcurrentMap map = redisson.getMap(name); - map.replace(secureRandom.nextInt(5), 2); + Assert.assertNotNull(map.replace(secureRandom.nextInt(5), 2)); } });