ThreadPoolFilter threadPoolFilter = new ThreadPoolFilter(); connector.getFilterChain().addLast( "threadPool", threadPoolFilter );  connector.getFilterChain().addLast( "logger", new LoggingFilter() );
    public void start( ReplicationConfiguration cfg ) throws Exception    {        // initialze client connection        //// initialize thread pool        ThreadPoolFilter threadPoolFilter = new ThreadPoolFilter();        connector.getFilterChain().addLast( "threadPool", threadPoolFilter );        //// add logger        connector.getFilterChain().addLast( "logger", new LoggingFilter() );                this.configuration = cfg;                monitor = new ConnectionMonitor();        monitor.start();    }