TopologyMgmtResourceImpl { public void stopTopology(String topologyName) throws Exception { Optional<Topology> tdop = TopologyMgmtResourceHelper.findById(dao.listTopologies(), topologyName); Topology topologyDef; if (tdop.isPresent()) { topologyDef = tdop.get(); } else { throw new Exception("Fail to find topology " + topologyName); } Nimbus.Client stormClient = NimbusClient.getConfiguredClient(getStormConf(null, topologyDef.getClusterName())).getClient(); stormClient.killTopology(topologyName); }  void startTopology(String topologyName); void stopTopology(String topologyName); List<TopologyStatus> getTopologies();  }
@Ignore @Test public void testStopTopology() throws Exception { topologyManager.startTopology(topologyName); Thread.sleep(10000); topologyManager.stopTopology(topologyName); }