| | |
|---|
| | | 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) ; |
|---|
