connectorConfig.getFilterChain().addLast( "protocol", new ProtocolCodecFilter( new ReplicationClientProtocolCodecFactory() ) );
    ClientConnectionManager( ReplicationService service )    {        this.service = service;                ExecutorThreadModel threadModel = ExecutorThreadModel.getInstance("mitosis");        threadModel.setExecutor(                new ThreadPoolExecutor(16, 16, 60, TimeUnit.SECONDS, new LinkedBlockingQueue() ));        connectorConfig.setThreadModel(threadModel);        //// add logger        connectorConfig.getFilterChain().addLast( "logger", new LoggingFilter() );    }