Динамические рабочие данные с использованием кварца

Question

Когда мой процесс получает сообщение, ему нужно запустить таймер и выполнить некоторую логику за X секунд. Эти задания должны храниться в хранилище JDBC, которое, насколько я могу судить, может не иметь отношения к этому вопросу.

Исходя из того, что я прочитал, я смогу назначить JobDataMap с различными значениями для похожих свойств одному классу Job, но я не могу найти какую-либо документацию или примеры для поддержки этого варианта использования. Возможно, мой Google-фу слаб.

Это имеет смысл? Есть один класс Job и каким-то образом хранить JobDataMap, чтобы заполнить этот класс Job и запускать его для каждого отдельного сообщения?

Answer 1

org.quartz.Trigger имеет как getJobDataMap() (что увеличит new единицу при необходимости), так и setJobDataMap(), чтобы получить JobDataMap триггера .

Самое простое использование будет:

Trigger t = new SimpleTrigger(...);
t.getJobDataMap().put("foo", "bar");

Для инициализации с существующей картой значений:

Map data = new HashMap();
data.put("foo", "bar");

t.setJobDataMap(new JobDataMap(data));

Чтобы получить данные при выполнении вашей работы

public void execute(JobExecutionContext context) throws JobExecutionException
{
   String fooValue = context.getMergedJobDataMap().get("foo");
}

---

Документация по JobDataMap в руководстве.

Answer 2

Привет Кансандо (вы говорите по-испански ???).Я собираюсь привести вам мой пример с Quartz.

public static void main(String[] args) {

        SchedulerFactory schedFact = new org.quartz.impl.StdSchedulerFactory();
        try {

            Scheduler sched;
            sched = schedFact.getScheduler();

            sched.start();

            JobDetail jobd = new JobDetail("instruccion", "instrucciones",
                    Mensaje.class);

//          TriggerExample trigger = new TriggerExample("instruccion",
//                  "instrucciones");

            jobd.setRequestsRecovery(true);
            SimpleTrigger trigger2 = new SimpleTrigger("lanzador principal", "lanzadores", "instruccion","instrucciones" , Calendar.getInstance().getTime(), null, 100, 10000);

            trigger2.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_FIRE_NOW);
            sched.scheduleJob(jobd, trigger2);

            //      
            // }
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    };


public class Mensaje implements Job {


    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        System.out.println("Hola Mundo");

    }

}


public class TriggerExample extends Trigger {

    /**
     * 
     */
    private static final long serialVersionUID = -4926331843008217753L;

    Date fechaAEjecutar;


    public TriggerExample(){

        super();
    }

    public TriggerExample(String name){
        super(name);
    }

    public TriggerExample(String name, String group){
        super(name, group);
    }

    public TriggerExample(String name, String group,String jobname, String jobgroup){
        super(name,group,jobname,jobgroup);
    }



    @Override
    public Date computeFirstFireTime(Calendar arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int executionComplete(JobExecutionContext arg0,
            JobExecutionException arg1) {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public Date getEndTime() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Date getFinalFireTime() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Date getFireTimeAfter(Date arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Date getNextFireTime() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Date getPreviousFireTime() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Date getStartTime() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public boolean mayFireAgain() {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void setEndTime(Date arg0) {
        // TODO Auto-generated method stub

    }

    @Override
    public void setStartTime(Date arg0) {
        this.fechaAEjecutar = arg0;
        System.out.println("Cargue la fecha el data con valor\n");
        System.out.println(this.fechaAEjecutar.getTime());

    }

    @Override
    public void triggered(Calendar arg0) {
        // TODO Auto-generated method stub

    }

    @Override
    public void updateAfterMisfire(Calendar arg0) {
        // TODO Auto-generated method stub

    }

    @Override
    public void updateWithNewCalendar(Calendar arg0, long arg1) {
        // TODO Auto-generated method stub

    }

    @Override
    protected boolean validateMisfireInstruction(int arg0) {
        // TODO Auto-generated method stub
        return false;
    }

}

В этой строке SimpleTrigger trigger2 = new SimpleTrigger ("руководитель Lanzador", "lanzadores", "instruccion", "instrucciones", Calendar.getInstance ().getTime (), null, 100, 10000);

Вы можете установить время для выполнения и повторения.