Merge pull request #3615 from ebean-orm/feature/3612-redis-exception

#3612 Catch all RedisException (rather than only IOException)

Author: rbygrave

ebean-redis/src/main/java/io/ebean/redis/DuelCache.java

@@ -1,7 +1,6 @@
 package io.ebean.redis;
 
 import io.ebean.cache.ServerCache;
-import io.ebean.cache.ServerCacheStatistics;
 import io.ebean.meta.MetricVisitor;
 import io.ebeaninternal.server.cache.DefaultServerCache;
 

ebean-redis/src/main/java/io/ebean/redis/RedisCacheFactory.java

@@ -281,7 +281,7 @@ private class DNearCacheNotify implements NearCacheNotify {
     public void invalidateKeys(String cacheKey, Set<Object> keySet) {
       try {
         sendMessage(messageInvalidateKeys(cacheKey, keySet));
-      } catch (IOException e) {
+      } catch (Exception e) {
         logger.log(ERROR, "failed to transmit invalidateKeys() message", e);
       }
     }
@@ -290,7 +290,7 @@ public void invalidateKeys(String cacheKey, Set<Object> keySet) {
     public void invalidateKey(String cacheKey, Object id) {
       try {
         sendMessage(messageInvalidateKey(cacheKey, id));
-      } catch (IOException e) {
+      } catch (Exception e) {
         logger.log(ERROR, "failed to transmit invalidateKeys() message", e);
       }
     }
@@ -299,7 +299,7 @@ public void invalidateKey(String cacheKey, Object id) {
     public void invalidateClear(String cacheKey) {
       try {
         sendMessage(messageInvalidateClear(cacheKey));
-      } catch (IOException e) {
+      } catch (Exception e) {
         logger.log(ERROR, "failed to transmit invalidateKeys() message", e);
       }
     }
@@ -422,7 +422,7 @@ private void processNearCacheMessage(byte[] message) {
               throw new IllegalStateException("Unexpected message type ? " + msgType);
           }
 
-        } catch (IOException | ClassNotFoundException e) {
+        } catch (Exception e) {
           logger.log(ERROR, "failed to decode near cache message [" + SafeEncoder.encode(message) + "] for cache:" + cacheKey, e);
           if (cacheKey != null) {
             nearCacheInvalidateClear(cacheKey);