ConfigurableIngestTopology { String getTopologyName(Configuration topologyConf) { String topologyName = topologyConf.getString(TOPOLOGY_NAME); Validate.notBlank(topologyName, "Missing topology name"); return topologyName; }  static void main(String[] args);  }
@Test public void testGetTopologyName() throws Exception { URL resource = TestResourceUtils.getResource(this.getClass(), "topology-config.xml"); XMLConfiguration conf = new XMLConfiguration(resource); assertThat(topology.getTopologyName(conf), is("TestTopology")); }