package com.dy.common.mw.channel.tcp;
|
|
import org.apache.mina.filter.codec.ProtocolCodecFactory;
|
import org.apache.mina.filter.codec.ProtocolEncoder;
|
import org.apache.mina.filter.codec.ProtocolDecoder;
|
import org.apache.mina.core.session.IoSession;
|
|
public class DataCodecFactory implements ProtocolCodecFactory {
|
|
private TcpUnitAdapter adapter ;
|
|
public DataCodecFactory(TcpUnitAdapter adapter) {
|
this.adapter = adapter ;
|
}
|
|
public ProtocolEncoder getEncoder(IoSession ioSession) {
|
return new DataEncoder();
|
}
|
|
public ProtocolDecoder getDecoder(IoSession ioSession) {
|
return new DataDecoder(adapter.newPrefixedDataAvailableHandle());
|
}
|
}
|
