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();
}

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 ( ) ; }
initializes the micro pipeline manager
