From bb62196bc1f5b2020e6a7467e25322fac3d39f51 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期三, 14 九月 2022 01:49:08 +0800
Subject: [PATCH] 优化 Redis 连接数
---
java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java b/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
index f394887..add6586 100644
--- a/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
+++ b/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
@@ -108,7 +108,7 @@
*
* @param cmdDataFlowContext
*/
- public static void multicastEvent(ICmdDataFlowContext cmdDataFlowContext) throws BusinessException {
+ public static void multicastEvent(ICmdDataFlowContext cmdDataFlowContext) throws Exception {
Assert.notNull(cmdDataFlowContext.getServiceCode(), "褰撳墠娌℃湁鍙鐞嗙殑涓氬姟淇℃伅锛�");
multicastEvent(cmdDataFlowContext.getServiceCode(), cmdDataFlowContext, null);
}
@@ -120,7 +120,7 @@
* @param serviceCode
* @param dataFlowContext
*/
- public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext) throws BusinessException {
+ public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext) throws Exception {
multicastEvent(serviceCode, dataFlowContext, null);
}
@@ -130,14 +130,15 @@
* @param serviceCode
* @param dataFlowContext 杩欎釜璁㈠崟淇℃伅锛屼互渚夸簬 渚﹀惉閭ｈ竟闇�瑕佺敤
*/
- public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext, String asyn) throws BusinessException {
+ public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext, String asyn) throws Exception {
try {
CmdEvent targetDataFlowEvent = new CmdEvent(serviceCode, dataFlowContext);
multicastEvent(serviceCode, targetDataFlowEvent, asyn);
} catch (Exception e) {
logger.error("鍙戝竷渚﹀惉澶辫触锛屽け璐ュ師鍥犱负锛�", e);
- throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, e.getMessage());
+ //throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, e.getMessage());
+ throw e;
}
}
--
Gitblit v1.8.0