From 1135c89deb50a080152f9086fc7b741c415ecd54 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期三, 12 二月 2025 17:00:14 +0800 Subject: [PATCH] 通信中间件增加功能: 1、实现消息心中; 2、开阀报、关阀报、报警数据都会在消息中间件存入消息; 3、在消息中心注册消息接收者,消息中心周期性向消息接收者推送消息。 --- pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/MwConfigVo.java | 11 +++++++++++ 1 files changed, 11 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/MwConfigVo.java b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/MwConfigVo.java index 1ee9d72..20a90e6 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/MwConfigVo.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/MwConfigVo.java @@ -17,6 +17,9 @@ public Integer heartbeatTimes = 3 ; //鍙戦�佹暟鎹鏁� public Integer sendTimes = 0 ; + //鍙戦�佸畬鏁版嵁鍚庯紝鏄惁鍏抽棴TCP杩炴帴锛�1鏄紝0鍚� + public Integer sendOverThenCloseConnect = 0 ; + /** * 瀵硅薄杞垚json * @return 杩斿洖 json @@ -100,4 +103,12 @@ public void setSendTimes(Integer sendTimes) { this.sendTimes = sendTimes; } + + public Integer getSendOverThenCloseConnect() { + return sendOverThenCloseConnect; + } + + public void setSendOverThenCloseConnect(Integer sendOverThenCloseConnect) { + this.sendOverThenCloseConnect = sendOverThenCloseConnect; + } } -- Gitblit v1.8.0