TimeCacheMap<String, Long> lastneedClean=new TimeCacheMap<String, Long>(3600);
@Override
public void run() {
StormClusterState clusterState = data.getStormClusterState();
List<String> active_topologys = clusterState.active_storms();
if (active_topologys != null){
for (String topologyid : active_topologys) {
StatusTransition.transition(data, topologyid, false, StatusType.monitor);
}
}