import org.apache.storm.Config;
import org.apache.storm.StormSubmitter;
import org.apache.storm.generated.AlreadyAliveException;
import org.apache.storm.generated.AuthorizationException;
import org.apache.storm.generated.InvalidTopologyException;
import org.apache.storm.topology.TopologyBuilder;

public class DummyTopology {
    public static void main(String[] args){

        String topologyName = args[0];
        int numWorkers = Integer.parseInt(args[1]);


        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("idSpout", new DummySpout());
        builder.setBolt("printBolt", new DummyBolt()).shuffleGrouping("idSpout");

        Config config = new Config();
        //config.setDebug(true);
        config.setNumWorkers(numWorkers);
        config.setNumEventLoggers(1);
        //config.put(Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS, 10000);
        //Config.TOPOLOGY_SPOUT_WAIT_STRATEGY
        //config.put(Config.)

        try {
            StormSubmitter.submitTopology(topologyName, config, builder.createTopology());
        } catch (AlreadyAliveException e) {
            e.printStackTrace();
        } catch (InvalidTopologyException e) {
            e.printStackTrace();
        } catch (AuthorizationException e) {
            e.printStackTrace();
        }
    }
}