publicvoidstarSendDataJob(Classclszz,intintervalMin,Stringtopcic){try{JobDetailsenddatajobDetail=JobBuilder.newJob(clszz).withIdentity(newJobKey(clszz.getSimpleName(),collectorJobGroup)).storeDurably().build();senddatajobDetail.getJobDataMap().put("topic",topcic);scheduler.addJob(senddatajobDetail,true);addTrigger(clszz.getSimpleName(),senddatajobDetail,intervalMin);}catch(SchedulerExceptione){log.error("startsenddatajoberror,jobname:{}",clszz.getName());log.error("startsenddatajoberror",e);e.printStackTrace();}}
料青山看我应如是
相关分类