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