ConfigurableIngestTopology { void submit() throws AlreadyAliveException, InvalidTopologyException { StormSubmitter.submitTopology(topologyName, stormConfig, builder.createTopology()); }  static void main(String[] args);  }
@Test public void testSubmit( @Injectable String topologyName, @Injectable Config stormConfig, @Injectable TopologyBuilder builder, @Injectable StormTopology stormTopology ) throws Exception { topology.topologyName = topologyName; topology.stormConfig = stormConfig; topology.builder = builder; new MockUp<StormSubmitter>() { @Mock void submitTopology(String name, Map stormConf, StormTopology topology) { } }; new Expectations() {{ builder.createTopology(); result = stormTopology; }}; topology.submit(); }