public void run(String[] args) throws Exception { final StormTopology topology = getTopology(); final Config config = getConfig(); if (args.length == 0) { submitTopologyLocalCluster(topology, config); } else { submitTopologyRemoteCluster(args[1], topology, config); } }