|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 初始化上行数据处理任务池 | 
|---|
|  |  |  | * 初始化 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void start(UnitCallbackInterface callback) throws Exception { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void stop(UnitCallbackInterface callback) throws Exception { | 
|---|
|  |  |  | overUpgradeTask() ; | 
|---|
|  |  |  | forceOverUpgradeTask() ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 停止当前升级任务 | 
|---|
|  |  |  | * 结束当前升级任务 | 
|---|
|  |  |  | * @throws Exception | 
|---|
|  |  |  | * @return null:结束任务成功,否则返回失败原因 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public void overUpgradeTask() throws Exception { | 
|---|
|  |  |  | public String forceOverUpgradeTask() throws Exception { | 
|---|
|  |  |  | if(manager != null ){ | 
|---|
|  |  |  | manager.overUpgradeTask() ; | 
|---|
|  |  |  | return manager.forceOverUpgradeTask() ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | return "通信中间件内部错误" ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | * @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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|