1.10.4

opensolon · Sep 28, 2022 · 69a7c1d · 69a7c1d
1 parent 0c04a1d
commit 69a7c1d
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/...loud-plugin/src/main/java/org/noear/solon/cloud/extend/jedis/impl/JedisEventConsumer.java b/...loud-plugin/src/main/java/org/noear/solon/cloud/extend/jedis/impl/JedisEventConsumer.java
@@ -12,6 +12,8 @@
 import org.slf4j.LoggerFactory;
 import redis.clients.jedis.JedisPubSub;
 
+import java.io.IOException;
+
 /**
  * @author noear
  * @since 1.10
@@ -34,8 +36,16 @@ public void onMessage(String channel, String message) {
             event.channel(eventChannelName);
 
             onReceive(event);
-        }catch (Throwable e){
-            EventBus.push(e);
+        }catch (Throwable ex){
+            ex = Utils.throwableUnwrap(ex);
+
+            EventBus.push(ex);
+
+            if (ex instanceof RuntimeException) {
+                throw (RuntimeException) ex;
+            } else {
+                throw new RuntimeException(ex);
+            }
         }
     }