From f16704bba5ee27b6fcd09b6951d403b10b9042ca Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=BE=99?= Date: Wed, 22 Jan 2025 16:52:59 +0800 Subject: [PATCH] =?UTF-8?q?feat:(feature/REQ-3342)=20=E8=A7=A3=E5=86=B3?= =?UTF-8?q?=E5=B9=BF=E6=92=AD=E6=A8=A1=E5=BC=8F=E4=B8=8B=E6=B6=88=E8=B4=B9?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=BC=82=E5=B8=B8=E8=BF=9B=E5=85=A5=E5=BB=B6?= =?UTF-8?q?=E8=BF=9F=E9=98=9F=E5=88=97=E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=8C?= =?UTF-8?q?=E7=8E=B0=E5=9C=A8=E7=9A=84=E5=9C=BA=E6=99=AF=E5=A6=82=E6=9E=9C?= =?UTF-8?q?=E6=B6=88=E8=B4=B9=E5=A4=B1=E8=B4=A5=EF=BC=8C=E5=86=8D=E6=AC=A1?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E4=B9=9F=E6=98=AF=E5=A4=B1=E8=B4=A5=EF=BC=8C?= =?UTF-8?q?=E6=89=80=E4=BB=A5=E5=90=8E=E7=BB=AD=E6=9C=89=E6=9C=AC=E5=9C=B0?= =?UTF-8?q?=E5=81=9A=E9=87=8D=E8=AF=95=E5=90=8E=E5=88=87=E6=8D=A2=E5=88=B0?= =?UTF-8?q?=E6=9C=AC=E5=9C=B0=E9=87=8D=E8=AF=95=EF=BC=8C=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E5=91=8A=E8=AD=A6=EF=BC=8C=E5=81=9A=E6=89=8B?= =?UTF-8?q?=E5=8A=A8=E8=A7=A6=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../config/RocketMQEventConfiguration.java | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) 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); + } } }