DelayedResponseOperatorRuntimeEnvironment implements Runnable, DelayedResponseCollector { public boolean isRunning() { return running; } DelayedResponseOperatorRuntimeEnvironment(final String processingNodeId, final String pipelineId, final DelayedResponseOperator delayedResponseOperator, final DelayedResponseOperatorWaitStrategy responseWaitStrategy,
			final StreamingMessageQueueConsumer queueConsumer, final StreamingMessageQueueProducer queueProducer);  DelayedResponseOperatorRuntimeEnvironment(final String processingNodeId, final String pipelineId, final DelayedResponseOperator delayedResponseOperator, final DelayedResponseOperatorWaitStrategy responseWaitStrategy,
			final StreamingMessageQueueConsumer queueConsumer, final StreamingMessageQueueProducer queueProducer, 
			final ExecutorService executorService); void run(); void retrieveMessages(); void shutdown(); boolean isRunning(); void setMessageCounter(Counter messageCounter);  }
@Test public void testConstructor_withValidInput() throws RequiredInputMissingException { DelayedResponseOperatorRuntimeEnvironment env = new DelayedResponseOperatorRuntimeEnvironment("proc-1", "pipe-1", Mockito.mock(DelayedResponseOperator.class), Mockito.mock(DelayedResponseOperatorWaitStrategy.class), Mockito.mock(StreamingMessageQueueConsumer.class), Mockito.mock(StreamingMessageQueueProducer.class)); Assert.assertTrue("The environment must be running", env.isRunning()); }