ServerPipelineInitializer.java

package com.osroyale.net;
 
import com.osroyale.Config;
import com.osroyale.net.codec.login.LoginDecoder;
import com.osroyale.net.codec.login.LoginResponseEncoder;
import com.osroyale.net.session.Session;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.haproxy.HAProxyMessageDecoder;
import io.netty.handler.timeout.IdleStateHandler;

public final class ServerPipelineInitializer extends ChannelInitializer<SocketChannel> {
 
    @Override
    protected void initChannel(SocketChannel ch) {
        final ChannelPipeline pipeline = ch.pipeline();
        ch.attr(Config.SESSION_KEY).setIfAbsent(new Session(ch));
 
        pipeline.addLast("timeout", new IdleStateHandler(Config.IDLE_TIMEOUT, 0, 0));
 
        if (Config.SUPPORT_HAPROXY) {
            pipeline.addLast("haproxy", new HAProxyMessageDecoder());
            pipeline.addLast("haproxy-handler", new HAProxyMessageHandler());
        }
 
        pipeline.addLast("login-decoder", new LoginDecoder());
        pipeline.addLast("login-encoder", new LoginResponseEncoder());
        pipeline.addLast("channel-handler", new ChannelHandler());
    }
 
}