public ConnectionProcessorPipe(final InputStream instream, final Filter[] filters, OutputStream outstream, final ConnectionLogger logger,  final Integer bufferSize) {
        this.instream =  new TroubleInputStream(instream, filters);
        this.outstream = outstream;
        this.bufferSize = bufferSize == null ? 1024 * 1024 : bufferSize;
        this.logger = logger;
    }