| | |
|---|
| | | package com.dy.rtuMw.server; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.channel.tcp.PrefixedDataAvailableHandle; |
|---|
| | | import com.dy.common.mw.channel.tcp.TcpConfigVo; |
|---|
| | | import com.dy.common.mw.channel.tcp.TcpIoSessionEventCallback; |
|---|
| | | import com.dy.common.mw.channel.tcp.TcpUnitAdapter; |
|---|
| | | import com.dy.common.mw.channel.tcp.*; |
|---|
| | | import com.dy.common.mw.protocol.PrefixedDataAvailableHandleImp; |
|---|
| | | import com.dy.rtuMw.server.forTcp.TcpIoSessionCallback; |
|---|
| | | |
|---|
| | |
|---|
| | | return new TcpIoSessionCallback() ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 模块停止时的回调 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public TcpUnitStopCallback newUnitStopCallback() { |
|---|
| | | return new com.dy.rtuMw.server.forTcp.TcpUnitStopCallback() ; |
|---|
| | | } |
|---|
| | | } |
|---|
