@Override
public String submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
        throws TException, TopologyAssignException {
    SubmitOptions options = new SubmitOptions(TopologyInitialStatus.ACTIVE);
    return submitTopologyWithOpts(name, uploadedJarLocation, jsonConf, topology, options);
}
 

void submitTopologyWithOpts(String topologyName, Map conf, StormTopology topology, SubmitOptions submitOpts)
throws AlreadyAliveException, InvalidTopologyException;
 

/**
 * Submits a topology to run on the cluster. A topology runs forever or until
 * explicitly killed.
 *
 * @param name the name of the storm.
 * @param stormConf the topology-specific configuration. See {@link Config}.
 * @param topology the processing to execute.
 * @param opts to manipulate the starting of the topology.
 * @throws AlreadyAliveException if a topology with this name is already running
 * @throws InvalidTopologyException if an invalid topology was submitted
 */
public static void submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts)
    throws AlreadyAliveException, InvalidTopologyException {
    submitTopology(name, stormConf, topology, opts, null);
}