MicroPipelineManager { public boolean hasPipeline(final String pipelineId) { return this.pipelines.containsKey(StringUtils.lowerCase(StringUtils.trim(pipelineId))); } MicroPipelineManager(final String processingNodeId, final ComponentRepository componentRepository, final int maxNumberOfThreads); protected  MicroPipelineManager(final String processingNodeId, final MicroPipelineFactory factory, final ExecutorService executorService); String executePipeline(final MicroPipelineConfiguration configuration); String shutdownPipeline(final String pipelineId); boolean hasPipeline(final String pipelineId); int getNumOfRegisteredPipelines(); Set<String> getPipelineIds(); Map<String, MicroPipelineConfiguration> getPipelineConfigurations(); void shutdown(); String getProcessingNodeId();  }
@Test public void testHasPipeline_withNonExistingId() throws Exception { MicroPipelineFactory factory = Mockito.mock(MicroPipelineFactory.class); Assert.assertFalse("Pipeline does not exist", new MicroPipelineManager("id", factory, executorService).hasPipeline("unknown-id")); }