registry.bind( new InetSocketAddress( 10101 ), new ServerHandler( true, new RunnableFactory() ), config );
registry.bind( new InetSocketAddress( 10101 ), new ReplicationServerProtocolHandler(this), config );
    private void startNetworking() throws Exception    {        registry = new SocketAcceptor();        IoServiceConfig config = new SocketAcceptorConfig();        config.getFilterChain().addLast( "protocol", new ProtocolCodecFilter( new ReplicationServerProtocolHandler( this ) ) );                // bind server protocol provider        registry.bind( new InetSocketAddress( 10101 ),               new ServerHandler( true, new RunnableFactory() ),               config );                clientConnectionManager.start( configuration );    }