| | |
| | | package com.dy.rtuMw.server; |
| | | |
| | | import com.dy.common.mw.channel.tcp.PrefixedDataAvailableHandle; |
| | | import com.dy.common.mw.channel.tcp.TcpConfigVo; |
| | | import com.dy.common.mw.channel.tcp.TcpIoSessionEventCallback; |
| | | import com.dy.common.mw.channel.tcp.TcpUnitAdapter; |
| | | import com.dy.common.mw.channel.tcp.*; |
| | | import com.dy.common.mw.protocol.PrefixedDataAvailableHandleImp; |
| | | import com.dy.rtuMw.server.forTcp.TcpIoSessionCallback; |
| | | |
| | |
| | | return new TcpIoSessionCallback() ; |
| | | } |
| | | |
| | | /** |
| | | * 模块停止时的回调 |
| | | */ |
| | | @Override |
| | | public TcpUnitStopCallback newUnitStopCallback() { |
| | | return new com.dy.rtuMw.server.forTcp.TcpUnitStopCallback() ; |
| | | } |
| | | } |