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