| New file | 
 |  |  | 
 |  |  | package com.dy.rtuMw.server; | 
 |  |  |  | 
 |  |  | import com.dy.common.mw.channel.tcp.*; | 
 |  |  | import com.dy.common.mw.protocol.PrefixedDataAvailableHandleImp; | 
 |  |  | import com.dy.rtuMw.server.forTcp.TcpIoSessionCallback; | 
 |  |  |  | 
 |  |  | public class AdapterImp_TcpUnit implements TcpUnitAdapter { | 
 |  |  | 	 | 
 |  |  |    private TcpConfigVo configVo ; | 
 |  |  |  | 
 |  |  |    @Override | 
 |  |  |    public TcpConfigVo getConfig() { | 
 |  |  |       return configVo; | 
 |  |  |    } | 
 |  |  | 	 | 
 |  |  |    public void setConfig(TcpConfigVo configVo){ | 
 |  |  |       this.configVo = configVo ; | 
 |  |  |    } | 
 |  |  |  | 
 |  |  |    @Override | 
 |  |  |    public PrefixedDataAvailableHandle newPrefixedDataAvailableHandle() { | 
 |  |  |       return new PrefixedDataAvailableHandleImp() ; | 
 |  |  |    } | 
 |  |  |  | 
 |  |  |    @Override | 
 |  |  |    public TcpIoSessionEventCallback newSessionEventCallback() { | 
 |  |  |       return new TcpIoSessionCallback() ; | 
 |  |  |    } | 
 |  |  |  | 
 |  |  |    /** | 
 |  |  |     * 模块停止时的回调 | 
 |  |  |     */ | 
 |  |  |    @Override | 
 |  |  |    public TcpUnitStopCallback newUnitStopCallback() { | 
 |  |  |       return new com.dy.rtuMw.server.forTcp.TcpUnitStopCallback() ; | 
 |  |  |    } | 
 |  |  | } |