Metacat

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DatabaseService;

<%@ page import="java.util.Vector,edu.ucsb.nceas.metacat.database.DBVersion,edu.ucsb.nceas.metacat.MetaCatVersion" %>

import org.quartz.SimpleTrigger;

	 * @param endCal

	 *            a calendar holding the end date of the job

	 * schedule a job one time with a given delay. The job is registered in the

	 * scheduler, but not persisted to the database. The delay is calculated

	 * from the time that this method is called.

	 * 

	 * @param jobName

	 *            the name of the job

	 * @param delay

	 *            the delay in seconds, minutes, hours or days from the time

	 *            this method is called (i.e. 30s, 5m, 2h, 1d)

	 * @param jobClassName

	 *            the job class name

	 * @param jobGroup

	 *            the job group name

	 * @param jobParams

	 *            a map of additional job parameters

	 * @param username

	 *            the user name

	 * @param groups

	 *            the user's group name

	 * @return a message saying that the job was scheduled

	 */

	public String scheduleDelayedJob(String jobName, String delay, String jobClassName, 

			String jobGroup, HashMap<String, String> jobParams, 

			String username, String[] groups) throws ServiceException {

        Class<Job> jobClass = null;

        try {

			jobClass = (Class<Job>) Class.forName(jobClassName);

			Calendar startCal = getStartDateFromDelay(delay);

			logMetacat.info("SchedulerService.scheduleDelayedJob - Scheduling job -- name: "

					+ jobName + ", delay: " + delay + ", job class name: " + jobClassName);

			// start the job in the job scheduler

			startOneTimeJob(jobName, startCal, jobClass, jobGroup,

					jobParams);

		} catch (ClassNotFoundException cnfe) {

			throw new ServiceException("SchedulerService.scheduleJob - Could not find class with name: "

							+ jobClassName + " : " + cnfe.getMessage());

		} 

		return "Scheduled: " + jobName;

	}

	/**

	 * @param jobGroup

	 *            the group of this job

	 * @param jobDetail

	 *            the job detail object

	 */

	private void startOneTimeJob(String jobName, Calendar startTime, Class<Job> jobClass, String jobGroup, HashMap<String, String> jobParams) throws ServiceException {

		JobDetail jobDetail = new JobDetail(jobName, jobGroup, jobClass);

		jobDetail.setJobDataMap(new JobDataMap(jobParams));

		SimpleTrigger trigger = new SimpleTrigger();

		trigger.setName(jobName);

		trigger.setStartTime(startTime.getTime());

		trigger.setRepeatCount(1);

		try {

			sched.scheduleJob(jobDetail, trigger);

		} catch (SchedulerException se) {

			throw new ServiceException("SchedulerService.scheduleSecondlyJob - Could not create " 

					+ "scheduler: " + se.getMessage());

		}

	}

	/**

	 * Schedule a job in the scheduler that has an interval based in seconds

	 * 

	 * @param jobName

	 *            the name of the job

	 * @param jobClass

	 *            the job class object

	 * @param startTime

	 *            the time of the first run