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