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