question: public MicroPipelineManager ( final String processingNodeId , final ComponentRepository componentRepository , final int maxNumberOfThreads ) throws RequiredInputMissingException { if ( componentRepository == null ) throw new RequiredInputMissingException ( "Missing required component repository" ) ; if ( StringUtils . isBlank ( processingNodeId ) ) throw new RequiredInputMissingException ( "Missing required processing node identifier" ) ; this . processingNodeId = StringUtils . lowerCase ( StringUtils . trim ( processingNodeId ) ) ; this . microPipelineFactory = new MicroPipelineFactory ( this . processingNodeId , componentRepository ) ; if ( maxNumberOfThreads == 1 ) this . executorService = Executors . newSingleThreadExecutor ( ) ; else if ( maxNumberOfThreads > 1 ) this . executorService = Executors . newFixedThreadPool ( maxNumberOfThreads ) ; else this . executorService = Executors . newCachedThreadPool ( ) ; }
target:  Initializes the micro pipeline manager