import org.apache.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public boolean killTopology(LocalCluster localCluster) throws Exception{
	KillOptions killOptions = new KillOptions();
	killOptions.set_wait_secs(1);
	localCluster.killTopologyWithOpts(topologyName, killOptions);
	try {//Give time to topology to be killed
		Thread.sleep(1200);
	} catch (InterruptedException e) {
		e.printStackTrace();
	}
	try{
		localCluster.getTopologyInfo(topologyName);
		return false;
	}catch(Exception ex){
		return true;
	}
}
 

import org.apache.storm.generated.KillOptions; //导入依赖的package包/类
protected void killTopology() {
  KillOptions ko = new KillOptions();
  ko.set_wait_secs(0);
  stormCluster.killTopologyWithOpts(sensorType, ko);
  try {
    // Actually wait for it to die.
    Thread.sleep(2000);
  } catch (InterruptedException e) {
    // Do nothing
  }
}
 

import org.apache.storm.generated.KillOptions; //导入依赖的package包/类
protected void killTopology() {
  KillOptions ko = new KillOptions();
  ko.set_wait_secs(0);
  stormCluster.killTopologyWithOpts(topologyName, ko);
  try {
    // Actually wait for it to die.
    Thread.sleep(2000);
  } catch (InterruptedException e) {
    // Do nothing
  }
}
 

import org.apache.storm.generated.KillOptions; //导入依赖的package包/类
public void killTopologyWithOpts(final String name, final KillOptions options) {
}
 

import org.apache.storm.generated.KillOptions; //导入依赖的package包/类
private KillOptions createKillOptions()
{
    KillOptions kop = new KillOptions();
    kop.set_wait_secs(stormConf.getKillWaitingSeconds());
    return kop;
}