public DelayedResponseOperatorRuntimeEnvironment(final String processingNodeId,final String pipelineId,final DelayedResponseOperator delayedResponseOperator,final DelayedResponseOperatorWaitStrategy responseWaitStrategy,final StreamingMessageQueueConsumer queueConsumer,final StreamingMessageQueueProducer queueProducer) throws RequiredInputMissingException {
  this(processingNodeId,pipelineId,delayedResponseOperator,responseWaitStrategy,queueConsumer,queueProducer,Executors.newCachedThreadPool());
  this.localExecutorService=true;
}

public DelayedResponseOperatorRuntimeEnvironment ( final String processingNodeId , final String pipelineId , final DelayedResponseOperator delayedResponseOperator , final DelayedResponseOperatorWaitStrategy responseWaitStrategy , final StreamingMessageQueueConsumer queueConsumer , final StreamingMessageQueueProducer queueProducer ) throws RequiredInputMissingException { this ( processingNodeId , pipelineId , delayedResponseOperator , responseWaitStrategy , queueConsumer , queueProducer , Executors . newCachedThreadPool ( ) ) ; this . localExecutorService = true ; }
initializes the runtime environment using the provied input
