| | |
|---|
| | | |
|---|
| | | import com.dy.common.mw.UnitAdapterInterface; |
|---|
| | | import com.dy.common.mw.UnitInterface; |
|---|
| | | import com.dy.common.mw.UnitStartedCallbackInterface; |
|---|
| | | import com.dy.common.mw.UnitCallbackInterface; |
|---|
| | | |
|---|
| | | public class RtuDataUnit implements UnitInterface { |
|---|
| | | |
|---|
| | |
|---|
| | | * 初始化上行数据处理任务池 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void start(UnitStartedCallbackInterface callback) throws Exception { |
|---|
| | | TaskPool.setTaskTreeCofig(new TreeParse().parseConfig()); |
|---|
| | | public void start(UnitCallbackInterface callback) throws Exception { |
|---|
| | | TaskPool.setTaskTreeCofig(new TreeParse().parseConfig(confVo.resourceLoader)); |
|---|
| | | callback.call(null) ; |
|---|
| | | System.out.println("RTU数据处理模块成功启动"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void stop(UnitStartedCallbackInterface callback) throws Exception { |
|---|
| | | public void stop(UnitCallbackInterface callback) throws Exception { |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
