Fixed - JCache.get() method swallows Redis errors.

4 years ago · e6e32a090a
parent 9bc32086ab
commit e6e32a090a
1 changed files with 5 additions and 0 deletions
--- a/redisson/src/main/java/org/redisson/jcache/JCache.java
+++ b/redisson/src/main/java/org/redisson/jcache/JCache.java
@ -202,6 +202,11 @@ public class JCache<K, V> extends RedissonObject implements Cache<K, V>, CacheAs

        RPromise<V> result = new RedissonPromise<>();
        future.onComplete((value, e) -> {
+            if (e != null) {
+                result.tryFailure(new CacheException(e));
+                return;
+            }
+
            if (value == null) {
                cacheManager.getStatBean(this).addMisses(1);
                if (config.isReadThrough()) {