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