类org.quartz.core.QuartzSchedulerResources源码实例Demo

下面列出了怎么用org.quartz.core.QuartzSchedulerResources的API类实例代码及写法,或者点击链接到github查看源代码。

@Override
protected Scheduler instantiate(QuartzSchedulerResources rsrcs, QuartzScheduler qs)
{
    Scheduler scheduler = super.instantiate(rsrcs, qs);
    JobStore jobStore = rsrcs.getJobStore();
    if (jobStore instanceof SchedulerAware)
    {
        ((SchedulerAware) jobStore).setScheduler(scheduler);
    }
    return scheduler;
}
 
源代码2 项目: AsuraFramework   文件: StdSchedulerFactory.java
protected Scheduler instantiate(QuartzSchedulerResources rsrcs, QuartzScheduler qs) {
    SchedulingContext schedCtxt = new SchedulingContext();
    schedCtxt.setInstanceId(rsrcs.getInstanceId());

    Scheduler scheduler = new StdScheduler(qs, schedCtxt);
    return scheduler;
}
 
源代码3 项目: lams   文件: StdSchedulerFactory.java
protected Scheduler instantiate(QuartzSchedulerResources rsrcs, QuartzScheduler qs) {

        Scheduler scheduler = new StdScheduler(qs);
        return scheduler;
    }
 
源代码4 项目: AsuraFramework   文件: DirectSchedulerFactory.java
/**
 * Same as
 * {@link DirectSchedulerFactory#createRemoteScheduler(String rmiHost, int rmiPort)},
 * with the addition of specifying the scheduler name, instance ID, and rmi
 * bind name. This scheduler can only be retrieved via
 * {@link DirectSchedulerFactory#getScheduler(String)}
 *
 * @param schedulerName
 *          The name for the scheduler.
 * @param schedulerInstanceId
 *          The instance ID for the scheduler.
 * @param rmiBindName
 *          The name of the remote scheduler in the RMI repository.  If null
 *          defaults to the generated unique identifier.
 * @param rmiHost
 *          The hostname for remote scheduler
 * @param rmiPort
 *          Port for the remote scheduler. The default RMI port is 1099.
 * @throws SchedulerException
 *           if the remote scheduler could not be reached.
 */
public void createRemoteScheduler(String schedulerName,
        String schedulerInstanceId, String rmiBindName, String rmiHost, int rmiPort)
    throws SchedulerException {
    SchedulingContext schedCtxt = new SchedulingContext();
    schedCtxt.setInstanceId(schedulerInstanceId);

    String uid = (rmiBindName != null) ? rmiBindName :
        QuartzSchedulerResources.getUniqueIdentifier(
            schedulerName, schedulerInstanceId);

    RemoteScheduler remoteScheduler = new RemoteScheduler(schedCtxt, uid,
            rmiHost, rmiPort);

    SchedulerRepository schedRep = SchedulerRepository.getInstance();
    schedRep.bind(remoteScheduler);
}
 
源代码5 项目: lams   文件: DirectSchedulerFactory.java
/**
 * Same as
 * {@link DirectSchedulerFactory#createRemoteScheduler(String rmiHost, int rmiPort)},
 * with the addition of specifying the scheduler name, instance ID, and rmi
 * bind name. This scheduler can only be retrieved via
 * {@link DirectSchedulerFactory#getScheduler(String)}
 *
 * @param schedulerName
 *          The name for the scheduler.
 * @param schedulerInstanceId
 *          The instance ID for the scheduler.
 * @param rmiBindName
 *          The name of the remote scheduler in the RMI repository.  If null
 *          defaults to the generated unique identifier.
 * @param rmiHost
 *          The hostname for remote scheduler
 * @param rmiPort
 *          Port for the remote scheduler. The default RMI port is 1099.
 * @throws SchedulerException
 *           if the remote scheduler could not be reached.
 */
public void createRemoteScheduler(String schedulerName,
        String schedulerInstanceId, String rmiBindName, String rmiHost, int rmiPort)
    throws SchedulerException {

    String uid = (rmiBindName != null) ? rmiBindName :
        QuartzSchedulerResources.getUniqueIdentifier(
            schedulerName, schedulerInstanceId);

    RemoteScheduler remoteScheduler = new RemoteScheduler(uid, rmiHost, rmiPort);

    SchedulerRepository schedRep = SchedulerRepository.getInstance();
    schedRep.bind(remoteScheduler);
    initialized = true;
}
 
 类所在包
 类方法
 同包方法