BaleenPipeline implements Runnable { public void pause() { LOGGER.info("Paused {} {}", getType(), name); paused = true; } @Deprecated  BaleenPipeline(
      String name,
      String originalYaml,
      IPipelineOrderer orderer,
      CollectionReader collectionReader,
      List<AnalysisEngine> annotators,
      List<AnalysisEngine> consumers);  BaleenPipeline(
      String name,
      PipelineConfiguration config,
      IPipelineOrderer orderer,
      CollectionReader collectionReader,
      List<AnalysisEngine> annotators,
      List<AnalysisEngine> consumers); String getName(); String originalConfig(); @SuppressWarnings("squid:RedundantThrowsDeclarationCheck" /* thrown from extending class */) String orderedConfig(); @Override void run(); void pause(); void unpause(); boolean isPaused(); void destroy(); CollectionReader collectionReader(); List<AnalysisEngine> annotators(); List<AnalysisEngine> consumers();  }
@Test public void testPause() throws IOException { BaleenPipeline bop = new BaleenPipeline( "Test Name", new YamlPipelineConfiguration(), new NoOpOrderer(), null, Collections.emptyList(), Collections.emptyList()); assertFalse(bop.isPaused()); bop.pause(); assertTrue(bop.isPaused()); bop.unpause(); assertFalse(bop.isPaused()); }