|  |  | 
 |  |  | import com.dy.aceMw.server.*; | 
 |  |  | import com.dy.aceMw.server.rtuData.RtuDataUnit; | 
 |  |  | import com.dy.aceMw.server.rtuData.RtuDataUnitConfigVo; | 
 |  |  | import com.dy.aceMw.server.tasks.FromRtuConstantTask; | 
 |  |  | import com.dy.aceMw.server.tasks.FromRtuComResultConstantTask; | 
 |  |  | import com.dy.aceMw.server.tasks.FromRtuDataConstantTask; | 
 |  |  | import com.dy.common.mw.UnitInterface; | 
 |  |  | import com.dy.common.mw.UnitStartedCallbackInterface; | 
 |  |  | import com.dy.common.mw.channel.rmi.RmiConfigVo; | 
 |  |  | import com.dy.common.mw.channel.rmi.RmiUnit; | 
 |  |  | import com.dy.common.mw.channel.tcp.TcpConfigVo; | 
 |  |  | 
 |  |  |          CoreUnit coreUnit = CoreUnit.getInstance(); | 
 |  |  |          coreUnit.setAdapter(coreAdap); | 
 |  |  |          CoreUnit.addConstantTask(new ToRtuConstantTask()); | 
 |  |  |          CoreUnit.addConstantTask(new FromRtuConstantTask()); | 
 |  |  |          CoreUnit.addConstantTask(new FromRtuDataConstantTask()); | 
 |  |  |          CoreUnit.addConstantTask(new FromRtuComResultConstantTask()); | 
 |  |  |          coreUnit.start(obj -> { | 
 |  |  |          }); | 
 |  |  |          units.add(coreUnit) ; |