/*  * Copyright 2004-2005 OpenSymphony  *  * Licensed under the Apache License, Version 2.0 (the "License"); you may not  * use this file except in compliance with the License. You may obtain a copy  * of the License at  *  *   http://www.apache.org/licenses/LICENSE-2.0  *    * Unless required by applicable law or agreed to in writing, software  * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT  * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the  * License for the specific language governing permissions and limitations  * under the License. *  *//* * Previously Copyright (c) 2001-2004 James House */package org.quartz.impl;import java.io.BufferedReader;import java.io.InputStreamReader;import org.quartz.Scheduler;import org.quartz.SchedulerException;import org.quartz.SchedulerFactory;import org.quartz.Trigger;/** * <p> * Instantiates an instance of Quartz Scheduler as a stand-alone program, if * the scheduler is configured for RMI it will be made available. * </p> *  * <p> * The main() method of this class currently accepts 0 or 1 arguemtns, if there * is an argument, and its value is <code>"console"</code>, then the program * will print a short message on the console (std-out) and wait for the user to * type "exit" - at which time the scheduler will be shutdown. * </p> *  * <p> * Future versions of this server should allow additional configuration for * responding to scheduler events by allowing the user to specify <code>{@link org.quartz.JobListener}</code>, * <code>{@link org.quartz.TriggerListener}</code> and <code>{@link org.quartz.SchedulerListener}</code> * classes. * </p> *  * <p> * Please read the Quartz FAQ entries about RMI before asking questions in the * forums or mail-lists. * </p> *  * @author James House */public class QuartzServer implements org.quartz.SchedulerListener {    /*     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     *      * Data members.     *      * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     */    private Scheduler sched = null;    /*     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     *      * Constructors.     *      * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     */    QuartzServer() {    }    /*     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     *      * Interface.     *      * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     */    public void serve(SchedulerFactory schedFact, boolean console)            throws Exception {        sched = schedFact.getScheduler();        sched.start();        try {            Thread.sleep(3000l);        } catch (Exception ignore) {        }        System.out.println("\n*** The scheduler successfully started.");        if (console) {            System.out.println("\n");            System.out                    .println("The scheduler will now run until you type \"exit\"");            System.out                    .println("   If it was configured to export itself via RMI,");            System.out.println("   then other process may now use it.");            BufferedReader rdr = new BufferedReader(new InputStreamReader(                    System.in));            while (true) {                System.out.print("Type 'exit' to shutdown the server: ");                if ("exit".equals(rdr.readLine())) {                    break;                }            }            System.out.println("\n...Shutting down server...");            sched.shutdown(true);        }    }    /*     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     *      * SchedulerListener Interface.     *      * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     */    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link org.quartz.JobDetail}</code>     * is scheduled.     * </p>     */    public void jobScheduled(Trigger trigger) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link org.quartz.JobDetail}</code>     * is unscheduled.     * </p>     */    public void jobUnscheduled(String triggerName, String triggerGroup) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link Trigger}</code>     * has reached the condition in which it will never fire again.     * </p>     */    public void triggerFinalized(Trigger trigger) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link Trigger}</code>     * or group of <code>{@link Trigger}s</code> has been paused.     * </p>     *      * <p>     * If a group was paused, then the <code>triggerName</code> parameter     * will be null.     * </p>     */    public void triggersPaused(String triggerName, String triggerGroup) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link Trigger}</code>     * or group of <code>{@link Trigger}s</code> has been un-paused.     * </p>     *      * <p>     * If a group was resumed, then the <code>triggerName</code> parameter     * will be null.     * </p>     */    public void triggersResumed(String triggerName, String triggerGroup) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link org.quartz.JobDetail}</code>     * or group of <code>{@link org.quartz.JobDetail}s</code> has been     * paused.     * </p>     *      * <p>     * If a group was paused, then the <code>jobName</code> parameter will be     * null.     * </p>     */    public void jobsPaused(String jobName, String jobGroup) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a <code>{@link org.quartz.JobDetail}</code>     * or group of <code>{@link org.quartz.JobDetail}s</code> has been     * un-paused.     * </p>     *      * <p>     * If a group was paused, then the <code>jobName</code> parameter will be     * null.     * </p>     */    public void jobsResumed(String jobName, String jobGroup) {    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> when a serious error has     * occured within the scheduler - such as repeated failures in the <code>JobStore</code>,     * or the inability to instantiate a <code>Job</code> instance when its     * <code>Trigger</code> has fired.     * </p>     *      * <p>     * The <code>getErrorCode()</code> method of the given SchedulerException     * can be used to determine more specific information about the type of     * error that was encountered.     * </p>     */    public void schedulerError(String msg, SchedulerException cause) {        System.err.println("*** " + msg);        cause.printStackTrace();    }    /**     * <p>     * Called by the <code>{@link Scheduler}</code> to inform the listener     * that it has shutdown.     * </p>     */    public void schedulerShutdown() {        System.out.println("\n*** The scheduler is now shutdown.");        sched = null;    }    /*     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     *      * Main Method.     *      * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~     */    public static void main(String[] args) throws Exception {        //    //Configure Log4J        //    org.apache.log4j.PropertyConfigurator.configure(        //      System.getProperty("log4jConfigFile", "log4j.properties"));        if (System.getSecurityManager() == null) {            System.setSecurityManager(new java.rmi.RMISecurityManager());        }        try {            QuartzServer server = new QuartzServer();            if (args.length == 0) server.serve(                    new org.quartz.impl.StdSchedulerFactory(), false);            else if (args.length == 1 && args[0].equalsIgnoreCase("console")) server                    .serve(new org.quartz.impl.StdSchedulerFactory(), true);            else {                System.err.println("\nUsage: QuartzServer [console]");            }        } catch (Exception e) {            e.printStackTrace();        }    }}