通信中间件增加功能： 1、实现消息心中； 2、开阀报、关阀报、报警数据都会在消息中间件存入消息； 3、在消息中心注册消息接收者，消息中心周期性向消息接...

liurunyu

2025-02-12 1135c89deb50a080152f9086fc7b741c415ecd54

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeUnit.java

@@ -39,7 +39,7 @@
    }

    /**
     * 初始化上行数据处理任务池
     * 初始化
     */
    @Override
    public void start(UnitCallbackInterface callback) throws Exception {
@@ -56,7 +56,7 @@

    @Override
    public void stop(UnitCallbackInterface callback) throws Exception {
        overUpgradeTask() ;
        forceOverUpgradeTask() ;
    }


@@ -73,12 +73,15 @@
    }

    /**
     * 停止当前升级任务
     * 结束当前升级任务
     * @throws Exception
     * @return null：结束任务成功，否则返回失败原因
     */
    public void overUpgradeTask() throws Exception {
    public String forceOverUpgradeTask() throws Exception {
        if(manager != null ){
            manager.overUpgradeTask() ;
            return manager.forceOverUpgradeTask() ;
        }else{
            return "通信中间件内部错误" ;
        }
    }

@@ -88,9 +91,9 @@
     * @param code
     * @param callback
     */
    public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callback){
    public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callback, Object ...objects){
        if(manager != null ){
            manager.trigger(rtuAddr, code, protocolName, protocolVersion, callback);
            manager.trigger(rtuAddr, code, protocolName, protocolVersion, callback, objects);
        }
    }