diff --git a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
index c27f8860..153112ac 100644
--- a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
+++ b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
@@ -80,7 +80,11 @@ public class RocketMQEventConfiguration {
 
         @Override
         public void onMessage(MessageExt message) {
-            super.onEvent(message, eventConsumer);
+            try {
+                super.onEvent(message, eventConsumer);
+            } catch (Exception ex) {
+                log.warn("consumer thrones message error,", ex);
+            }
         }
     }
 
@@ -99,7 +103,11 @@ public class RocketMQEventConfiguration {
 
         @Override
         public void onMessage(MessageExt message) {
-            super.onEvent(message, eventConsumer);
+            try {
+                super.onEvent(message, eventConsumer);
+            } catch (Exception ex) {
+                log.warn("consumer tyr message error,", ex);
+            }
         }
     }
 
@@ -118,7 +126,11 @@ public class RocketMQEventConfiguration {
 
         @Override
         public void onMessage(MessageExt message) {
-            super.onEvent(message, eventConsumer);
+            try {
+                super.onEvent(message, eventConsumer);
+            } catch (Exception ex) {
+                log.warn("consumer apisixPlat message error,", ex);
+            }
         }
     }