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