|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 初始化上行数据处理任务池 | 
|---|
|  |  |  | * 初始化 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void start(UnitCallbackInterface callback) throws Exception { | 
|---|
|  |  |  | 
|---|
|  |  |  | * @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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|