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