ConfigurableIngestTopology { void submitLocal(ILocalCluster cluster) throws AlreadyAliveException, InvalidTopologyException { stormConfig.setDebug(true); cluster.submitTopology(topologyName, stormConfig, builder.createTopology()); }  static void main(String[] args);  }
@Test public void testSubmitLocal( @Injectable String topologyName, @Injectable Config stormConfig, @Injectable TopologyBuilder builder, @Injectable ILocalCluster cluster, @Injectable StormTopology stormTopology ) throws Exception { topology.topologyName = topologyName; topology.stormConfig = stormConfig; topology.builder = builder; new Expectations() {{ builder.createTopology(); result = stormTopology; cluster.submitTopology(topologyName, stormConfig, stormTopology); }}; topology.submitLocal(cluster); }