Java 类org.quartz.impl.matchers.KeyMatcher 实例源码

/**
 * The main method.
 *
 * @param args the arguments
 * @throws SchedulerException the scheduler exception
 */
public static void main(String[] args) throws SchedulerException {
    System.out.println("Starting MainApplication...");
    System.out.println("Starting Scheduler...");

    app.sched_fact = new org.quartz.impl.StdSchedulerFactory();
    app.scheduler = app.sched_fact.getScheduler();
    app.setIsinMutexMap(new LinkedHashMap<String, ReentrantLock>());
    app.scheduler.start();

    System.out.println("Creating Jobs...");

    app.createJobs();
    System.out.println("Adding Jobs...");

    if(!app.addJobsToScheduler()) {
        System.out.println("Adding Jobs to Scheduler failed.");
        return;
    }

    System.out.println("Creating Listeners...");

    CompanyIndexerListener company_index_listener = new CompanyIndexerListener("company_index_listener");
    app.scheduler.getListenerManager().addJobListener(company_index_listener, KeyMatcher.keyEquals(app.company_indexer_job.getKey()));

    IsinMutexMapListener isin_mutex_map_listener = new IsinMutexMapListener("isin_mutex_map_listener");
    app.scheduler.getListenerManager().addJobListener(isin_mutex_map_listener, KeyMatcher.keyEquals(app.isin_mutex_map_creation_job.getKey()));

    System.out.println("Creating Triggers...");

    /*Trigger daily_trigger = newTrigger()
            .withIdentity("Daily Trigger", "Crawler Triggers")
            .withSchedule(cronSchedule("0 25 17 ? * MON-FRI"))
            .build();

    Trigger weekly_trigger = newTrigger()
            .withIdentity("Weekly Trigger", "Crawler Triggers")
            .withSchedule(cronSchedule("0 00 15 ? * SAT-SUN"))
            .build();

    app.scheduler.scheduleJob(app.market_values_crawler_job, daily_trigger);
    app.scheduler.scheduleJob(app.company_indexer_job, weekly_trigger);*/

    MainApplication.app.getMarketValuesCrawlerJob().getJobDataMap().put("to_crawl", MarketValuesCrawler.ToCrawl.HISTORY.ordinal());
    //app.getScheduler().triggerJob(MainApplication.app.company_indexer_job.getKey());
    app.getScheduler().triggerJob(MainApplication.app.getIsinMutexMapCreationJob().getKey());
    //app.getScheduler().triggerJob(MainApplication.app.history_market_values_crawler_job.getKey());
    //app.getScheduler().triggerJob(MainApplication.app.market_values_crawler_job.getKey());



}