opensource
/
fine-third
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity
Browse Source

反射

10.0
daniel 7 years ago
parent
b6d6431c58
commit
c2900fb8aa
8 changed files with 89 additions and 89 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 4
      fine-quartz/src/com/fr/third/v2/org/quartz/core/QuartzScheduler.java
  2. 64
      fine-quartz/src/com/fr/third/v2/org/quartz/core/mbeans-descriptors.xml
  3. 4
      fine-quartz/src/com/fr/third/v2/org/quartz/ee/jmx/jboss/JBoss4RMIRemoteMBeanScheduler.java
  4. 2
      fine-quartz/src/com/fr/third/v2/org/quartz/ee/servlet/QuartzInitializerListener.java
  5. 2
      fine-quartz/src/com/fr/third/v2/org/quartz/ee/servlet/QuartzInitializerServlet.java
  6. 98
      fine-quartz/src/com/fr/third/v2/org/quartz/impl/StdSchedulerFactory.java
  7. 2
      fine-quartz/src/com/fr/third/v2/org/quartz/simpl/SystemPropertyInstanceIdGenerator.java
  8. 2
      fine-quartz/src/com/fr/third/v2/org/quartz/utils/DBConnectionManager.java

4
fine-quartz/src/com/fr/third/v2/org/quartz/core/QuartzScheduler.java
Unescape View File

@ -275,7 +275,7 @@ public class QuartzScheduler implements RemotableQuartzScheduler {
// (!MGMT_SVR_BY_BIND.containsKey(managementRESTServiceConfiguration.getBind()))
// {
// Class<?> managementServerImplClass =
// Class.forName("org.quartz.management.ManagementServerImpl");
// Class.forName("com.fr.third.v2.org.quartz.management.ManagementServerImpl");
// Class<?> managementRESTServiceConfigurationClass[] = new Class[] {
// managementRESTServiceConfiguration.getClass() };
// Constructor<?> managementRESTServiceConfigurationConstructor =
@ -331,7 +331,7 @@ public class QuartzScheduler implements RemotableQuartzScheduler {
private boolean shouldRunUpdateCheck() {
if(resources.isRunUpdateCheck() && !Boolean.getBoolean(StdSchedulerFactory.PROP_SCHED_SKIP_UPDATE_CHECK) &&
!Boolean.getBoolean("org.terracotta.quartz.skipUpdateCheck")) {
!Boolean.getBoolean("com.fr.third.v2.org.terracotta.quartz.skipUpdateCheck")) {
return true;
}
return false;

64
fine-quartz/src/com/fr/third/v2/org/quartz/core/mbeans-descriptors.xml
Unescape View File

@ -30,45 +30,45 @@
<operation name="getCurrentlyExecutingJobs" description="Get a list of JobExecutionContext objects that represent all currently executing Jobs in this scheduler instance." impact="INFO" returnType="java.util.List"/>
<operation name="scheduleJob" description="Add the given JobDetail to the Scheduler, and associate the given Trigger with it." impact="ACTION" returnType="java.util.Date">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobDetail" type="com.fr.third.v2.org.quartz.JobDetail" description="The JobDetail to schedule."/>
<parameter name="trigger" type="com.fr.third.v2.org.quartz.Trigger" description="The Trigger to schedule."/>
</operation>
<operation name="scheduleJob" description="Schedule the given Trigger with the Job identified by the Trigger's settings." impact="ACTION" returnType="java.util.Date">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="trigger" type="com.fr.third.v2.org.quartz.Trigger" description="The Trigger to schedule."/>
</operation>
<operation name="unscheduleJob" description="Remove the indicated Triggerfrom the scheduler." impact="ACTION" returnType="boolean">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the Trigger to unschedule."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Trigger to unschedule."/>
</operation>
<operation name="rescheduleJob" description="Remove (delete) the Trigger with the given name, and store the new given one - which must be associated with the same job (the new trigger must have the job name and group specified) - however, the new trigger need not have the same name as the old trigger." impact="ACTION" returnType="java.util.Date">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the Trigger to be replaced."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Trigger to be replaced."/>
<parameter name="newTrigger" type="com.fr.third.v2.org.quartz.Trigger" description="The new Trigger to be stored."/>
</operation>
<operation name="addJob" description="Add the given Job to the Scheduler - with no associated Trigger." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobDetail" type="com.fr.third.v2.org.quartz.JobDetail" description="The JobDetail to add."/>
<parameter name="replace" type="boolean" description="Whether or not to replace an existing Job with the given one."/>
</operation>
<operation name="deleteJob" description="Delete the identified Job from the Scheduler - and any associated Triggers." impact="ACTION" returnType="boolean">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the Job to delete."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Job to delete."/>
</operation>
<operation name="triggerJob" description="Trigger the identified JobDetail (execute it now) - the generated trigger will be non-volatile." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the Job to trigger."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Job to trigger."/>
<parameter name="jobDataMap" type="com.fr.third.v2.org.quartz.JobDataMap" description="The (possibly null) JobDataMap to be associated with the trigger that fires the job immediately."/>
</operation>
<operation name="triggerJobWithVolatileTrigger" description="Trigger the identified JobDetail (execute it now) - the generated trigger will be volatile." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the Job to trigger."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Job to trigger."/>
<parameter name="jobDataMap" type="com.fr.third.v2.org.quartz.JobDataMap" description="The (possibly null) JobDataMap to be associated with the trigger that fires the job immediately."/>
@ -76,109 +76,109 @@
<operation name="interrupt" description="Request the interruption, within this scheduler instance, of all currently executing instances of the identified Job, which must be an implementor of the InterruptableJob interface." impact="ACTION" returnType="boolean">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the trigger to interrupt."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The name of the trigger group to interrupt."/>
</operation>
<operation name="pauseJob" description="Pause the JobDetail with the given name - by pausing all of its current Triggers." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the Job to pause."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Job to pause."/>
</operation>
<operation name="pauseJobGroup" description="Pause all of the JobDetails in the given group - by pausing all of theirTriggers." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Jobs to pause."/>
</operation>
<operation name="pauseTrigger" description="Pause the Trigger with the given name." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the Trigger to pause."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Trigger to pause."/>
</operation>
<operation name="pauseTriggerGroup" description="Pause all of the Triggers in the given group." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Triggers to pause."/>
</operation>
<operation name="resumeJob" description="Resume (un-pause) the JobDetail with the given name." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the Job to resume."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Job to resume."/>
</operation>
<operation name="resumeJobGroup" description="Resume (un-pause) all of the JobDetails in the given group." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobGroupName" type="java.lang.String" description="The group name of the Jobs to resume."/>
</operation>
<operation name="resumeTrigger" description="Resume (un-pause) the Trigger with the given name." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the Trigger to resume."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Trigger to resume."/>
</operation>
<operation name="resumeTriggerGroup" description="Resume (un-pause) all of the Triggers in the given group." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The group name of the Triggers to resume."/>
</operation>
<operation name="pauseAll" description="Pause all triggers - similar to calling pauseTriggerGroup(group) on every group, however, after using this method resumeAll() must be called to clear the scheduler's state of 'remembering' that all new triggers will be paused as they are added." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="resumeAll" description="Resume (un-pause) all triggers - similar to calling resumeTriggerGroup(group) on every group." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="getPausedTriggerGroups" description="Get the names of all Trigger groups that are paused." impact="INFO" returnType="java.util.Set">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="getJobGroupNames" description="Get the names of all known JobDetail groups." impact="INFO" returnType="[Ljava.lang.String;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="getJobNames" description="Get the names of all the JobDetails in the given group." impact="INFO" returnType="[Ljava.lang.String;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobGroupName" type="java.lang.String" description="The job group name."/>
</operation>
<operation name="getTriggersOfJob" description="Get all Triggers that are associated with the identified JobDetail." impact="INFO" returnType="[Lorg.quartz.Trigger;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the job."/>
<parameter name="jobGroupName" type="java.lang.String" description="The name of the job group."/>
</operation>
<operation name="getTriggerGroupNames" description="Get the names of all known Trigger groups." impact="INFO" returnType="[Ljava.lang.String;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="getTriggerNames" description="Get the names of all the Triggers in the given group." impact="INFO" returnType="[Ljava.lang.String;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The trigger group name."/>
</operation>
<operation name="getJobDetail" description="Get the JobDetail for the Job instance with the given name and group." impact="INFO" returnType="[Lorg.quartz.JobDetail;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="jobName" type="java.lang.String" description="The name of the job."/>
<parameter name="jobGroupName" type="java.lang.String" description="The name of the job group."/>
</operation>
<operation name="getTrigger" description="Get the Trigger instance with the given name and group." impact="INFO" returnType="[Lorg.quartz.Trigger;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the trigger."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The name of the trigger group."/>
</operation>
<operation name="getTriggerState" description="Get the current state of the identified Trigger." impact="INFO" returnType="int">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="triggerName" type="java.lang.String" description="The name of the trigger."/>
<parameter name="triggerGroupName" type="java.lang.String" description="The name of the trigger group."/>
</operation>
<operation name="addCalendar" description="Add (register) the given Calendar to the scheduler." impact="ACTION" returnType="void">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="calendarName" type="java.lang.String" description="Name of the calendar to add."/>
<parameter name="calendar" type="com.fr.third.v2.org.quartz.Calendar" description="The Calendar instance to add."/>
<parameter name="replace" type="boolean" description="Whether to allow replacing an existing Calendar instance."/>
<parameter name="updateTriggers" type="boolean" description="Whether or not to update existing triggers that referenced the already existing calendar so that they are 'correct' based on the new trigger."/>
</operation>
<operation name="deleteCalendar" description="Delete the identified Calendar from the scheduler." impact="ACTION" returnType="boolean">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="calendarName" type="java.lang.String" description="Name of the Calendar to delete."/>
</operation>
<operation name="getCalendar" description="Get the Calendar instance with the given name." impact="INFO" returnType="com.fr.third.v2.org.quartz.Calendar">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="calendarName" type="java.lang.String" description="Name of the Calendar to get."/>
</operation>
<operation name="getCalendarNames" description="Get the names of all registered Calendars." impact="INFO" returnType="[Ljava.lang.String;">
<parameter name="schedulingContext" type="org.quartz.core.SchedulingContext" description="The scheduling context."/>
<parameter name="schedulingContext" type="com.fr.third.v2.org.quartz.core.SchedulingContext" description="The scheduling context."/>
</operation>
<operation name="addGlobalJobListener" description="Add the given JobListener to the scheduler's global list." impact="ACTION" returnType="void">

4
fine-quartz/src/com/fr/third/v2/org/quartz/ee/jmx/jboss/JBoss4RMIRemoteMBeanScheduler.java
Unescape View File

@ -96,8 +96,8 @@ public class JBoss4RMIRemoteMBeanScheduler extends RemoteMBeanScheduler {
*/
protected Properties getContextProperties() {
Properties props = new Properties();
props.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
props.put(Context.INITIAL_CONTEXT_FACTORY, "com.fr.third.v2.org.jnp.interfaces.NamingContextFactory");
props.put(Context.URL_PKG_PREFIXES, "com.fr.third.v2.org.jboss.naming:org.jnp.interfaces");
props.put(Context.PROVIDER_URL, providerURL);
return props;

2
fine-quartz/src/com/fr/third/v2/org/quartz/ee/servlet/QuartzInitializerListener.java
Unescape View File

@ -125,7 +125,7 @@ import org.slf4j.LoggerFactory;
*/
public class QuartzInitializerListener implements ServletContextListener {
public static final String QUARTZ_FACTORY_KEY = "org.quartz.impl.StdSchedulerFactory.KEY";
public static final String QUARTZ_FACTORY_KEY = "com.fr.third.v2.org.quartz.impl.StdSchedulerFactory.KEY";
private boolean performShutdown = true;
private boolean waitOnShutdown = false;

2
fine-quartz/src/com/fr/third/v2/org/quartz/ee/servlet/QuartzInitializerServlet.java
Unescape View File

@ -144,7 +144,7 @@ public class QuartzInitializerServlet extends HttpServlet {
*/
private static final long serialVersionUID = 1L;
public static final String QUARTZ_FACTORY_KEY = "org.quartz.impl.StdSchedulerFactory.KEY";
public static final String QUARTZ_FACTORY_KEY = "com.fr.third.v2.org.quartz.impl.StdSchedulerFactory.KEY";
private boolean performShutdown = true;
private boolean waitOnShutdown = false;

98
fine-quartz/src/com/fr/third/v2/org/quartz/impl/StdSchedulerFactory.java
Unescape View File

@ -122,76 +122,76 @@ public class StdSchedulerFactory implements SchedulerFactory {
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
public static final String PROPERTIES_FILE = "org.quartz.properties";
public static final String PROPERTIES_FILE = "com.fr.third.v2.org.quartz.properties";
public static final String PROP_SCHED_INSTANCE_NAME = "org.quartz.scheduler.instanceName";
public static final String PROP_SCHED_INSTANCE_NAME = "com.fr.third.v2.org.quartz.scheduler.instanceName";
public static final String PROP_SCHED_INSTANCE_ID = "org.quartz.scheduler.instanceId";
public static final String PROP_SCHED_INSTANCE_ID = "com.fr.third.v2.org.quartz.scheduler.instanceId";
public static final String PROP_SCHED_INSTANCE_ID_GENERATOR_PREFIX = "org.quartz.scheduler.instanceIdGenerator";
public static final String PROP_SCHED_INSTANCE_ID_GENERATOR_PREFIX = "com.fr.third.v2.org.quartz.scheduler.instanceIdGenerator";
public static final String PROP_SCHED_INSTANCE_ID_GENERATOR_CLASS =
PROP_SCHED_INSTANCE_ID_GENERATOR_PREFIX + ".class";
public static final String PROP_SCHED_THREAD_NAME = "org.quartz.scheduler.threadName";
public static final String PROP_SCHED_THREAD_NAME = "com.fr.third.v2.org.quartz.scheduler.threadName";
public static final String PROP_SCHED_SKIP_UPDATE_CHECK = "org.quartz.scheduler.skipUpdateCheck";
public static final String PROP_SCHED_SKIP_UPDATE_CHECK = "com.fr.third.v2.org.quartz.scheduler.skipUpdateCheck";
public static final String PROP_SCHED_BATCH_TIME_WINDOW = "org.quartz.scheduler.batchTriggerAcquisitionFireAheadTimeWindow";
public static final String PROP_SCHED_BATCH_TIME_WINDOW = "com.fr.third.v2.org.quartz.scheduler.batchTriggerAcquisitionFireAheadTimeWindow";
public static final String PROP_SCHED_MAX_BATCH_SIZE = "org.quartz.scheduler.batchTriggerAcquisitionMaxCount";
public static final String PROP_SCHED_MAX_BATCH_SIZE = "com.fr.third.v2.org.quartz.scheduler.batchTriggerAcquisitionMaxCount";
public static final String PROP_SCHED_JMX_EXPORT = "org.quartz.scheduler.jmx.export";
public static final String PROP_SCHED_JMX_EXPORT = "com.fr.third.v2.org.quartz.scheduler.jmx.export";
public static final String PROP_SCHED_JMX_OBJECT_NAME = "org.quartz.scheduler.jmx.objectName";
public static final String PROP_SCHED_JMX_OBJECT_NAME = "com.fr.third.v2.org.quartz.scheduler.jmx.objectName";
public static final String PROP_SCHED_JMX_PROXY = "org.quartz.scheduler.jmx.proxy";
public static final String PROP_SCHED_JMX_PROXY = "com.fr.third.v2.org.quartz.scheduler.jmx.proxy";
public static final String PROP_SCHED_JMX_PROXY_CLASS = "org.quartz.scheduler.jmx.proxy.class";
public static final String PROP_SCHED_JMX_PROXY_CLASS = "com.fr.third.v2.org.quartz.scheduler.jmx.proxy.class";
public static final String PROP_SCHED_RMI_EXPORT = "org.quartz.scheduler.rmi.export";
public static final String PROP_SCHED_RMI_EXPORT = "com.fr.third.v2.org.quartz.scheduler.rmi.export";
public static final String PROP_SCHED_RMI_PROXY = "org.quartz.scheduler.rmi.proxy";
public static final String PROP_SCHED_RMI_PROXY = "com.fr.third.v2.org.quartz.scheduler.rmi.proxy";
public static final String PROP_SCHED_RMI_HOST = "org.quartz.scheduler.rmi.registryHost";
public static final String PROP_SCHED_RMI_HOST = "com.fr.third.v2.org.quartz.scheduler.rmi.registryHost";
public static final String PROP_SCHED_RMI_PORT = "org.quartz.scheduler.rmi.registryPort";
public static final String PROP_SCHED_RMI_PORT = "com.fr.third.v2.org.quartz.scheduler.rmi.registryPort";
public static final String PROP_SCHED_RMI_SERVER_PORT = "org.quartz.scheduler.rmi.serverPort";
public static final String PROP_SCHED_RMI_SERVER_PORT = "com.fr.third.v2.org.quartz.scheduler.rmi.serverPort";
public static final String PROP_SCHED_RMI_CREATE_REGISTRY = "org.quartz.scheduler.rmi.createRegistry";
public static final String PROP_SCHED_RMI_CREATE_REGISTRY = "com.fr.third.v2.org.quartz.scheduler.rmi.createRegistry";
public static final String PROP_SCHED_RMI_BIND_NAME = "org.quartz.scheduler.rmi.bindName";
public static final String PROP_SCHED_RMI_BIND_NAME = "com.fr.third.v2.org.quartz.scheduler.rmi.bindName";
public static final String PROP_SCHED_WRAP_JOB_IN_USER_TX = "org.quartz.scheduler.wrapJobExecutionInUserTransaction";
public static final String PROP_SCHED_WRAP_JOB_IN_USER_TX = "com.fr.third.v2.org.quartz.scheduler.wrapJobExecutionInUserTransaction";
public static final String PROP_SCHED_USER_TX_URL = "org.quartz.scheduler.userTransactionURL";
public static final String PROP_SCHED_USER_TX_URL = "com.fr.third.v2.org.quartz.scheduler.userTransactionURL";
public static final String PROP_SCHED_IDLE_WAIT_TIME = "org.quartz.scheduler.idleWaitTime";
public static final String PROP_SCHED_IDLE_WAIT_TIME = "com.fr.third.v2.org.quartz.scheduler.idleWaitTime";
public static final String PROP_SCHED_DB_FAILURE_RETRY_INTERVAL = "org.quartz.scheduler.dbFailureRetryInterval";
public static final String PROP_SCHED_DB_FAILURE_RETRY_INTERVAL = "com.fr.third.v2.org.quartz.scheduler.dbFailureRetryInterval";
public static final String PROP_SCHED_MAKE_SCHEDULER_THREAD_DAEMON = "org.quartz.scheduler.makeSchedulerThreadDaemon";
public static final String PROP_SCHED_MAKE_SCHEDULER_THREAD_DAEMON = "com.fr.third.v2.org.quartz.scheduler.makeSchedulerThreadDaemon";
public static final String PROP_SCHED_SCHEDULER_THREADS_INHERIT_CONTEXT_CLASS_LOADER_OF_INITIALIZING_THREAD = "org.quartz.scheduler.threadsInheritContextClassLoaderOfInitializer";
public static final String PROP_SCHED_SCHEDULER_THREADS_INHERIT_CONTEXT_CLASS_LOADER_OF_INITIALIZING_THREAD = "com.fr.third.v2.org.quartz.scheduler.threadsInheritContextClassLoaderOfInitializer";
public static final String PROP_SCHED_CLASS_LOAD_HELPER_CLASS = "org.quartz.scheduler.classLoadHelper.class";
public static final String PROP_SCHED_CLASS_LOAD_HELPER_CLASS = "com.fr.third.v2.org.quartz.scheduler.classLoadHelper.class";
public static final String PROP_SCHED_JOB_FACTORY_CLASS = "org.quartz.scheduler.jobFactory.class";
public static final String PROP_SCHED_JOB_FACTORY_CLASS = "com.fr.third.v2.org.quartz.scheduler.jobFactory.class";
public static final String PROP_SCHED_JOB_FACTORY_PREFIX = "org.quartz.scheduler.jobFactory";
public static final String PROP_SCHED_JOB_FACTORY_PREFIX = "com.fr.third.v2.org.quartz.scheduler.jobFactory";
public static final String PROP_SCHED_INTERRUPT_JOBS_ON_SHUTDOWN = "org.quartz.scheduler.interruptJobsOnShutdown";
public static final String PROP_SCHED_INTERRUPT_JOBS_ON_SHUTDOWN = "com.fr.third.v2.org.quartz.scheduler.interruptJobsOnShutdown";
public static final String PROP_SCHED_INTERRUPT_JOBS_ON_SHUTDOWN_WITH_WAIT = "org.quartz.scheduler.interruptJobsOnShutdownWithWait";
public static final String PROP_SCHED_INTERRUPT_JOBS_ON_SHUTDOWN_WITH_WAIT = "com.fr.third.v2.org.quartz.scheduler.interruptJobsOnShutdownWithWait";
public static final String PROP_SCHED_CONTEXT_PREFIX = "org.quartz.context.key";
public static final String PROP_SCHED_CONTEXT_PREFIX = "com.fr.third.v2.org.quartz.context.key";
public static final String PROP_THREAD_POOL_PREFIX = "org.quartz.threadPool";
public static final String PROP_THREAD_POOL_PREFIX = "com.fr.third.v2.org.quartz.threadPool";
public static final String PROP_THREAD_POOL_CLASS = "org.quartz.threadPool.class";
public static final String PROP_THREAD_POOL_CLASS = "com.fr.third.v2.org.quartz.threadPool.class";
public static final String PROP_JOB_STORE_PREFIX = "org.quartz.jobStore";
public static final String PROP_JOB_STORE_PREFIX = "com.fr.third.v2.org.quartz.jobStore";
public static final String PROP_JOB_STORE_LOCK_HANDLER_PREFIX = PROP_JOB_STORE_PREFIX + ".lockHandler";
@ -201,11 +201,11 @@ public class StdSchedulerFactory implements SchedulerFactory {
public static final String PROP_SCHED_NAME = "schedName";
public static final String PROP_JOB_STORE_CLASS = "org.quartz.jobStore.class";
public static final String PROP_JOB_STORE_CLASS = "com.fr.third.v2.org.quartz.jobStore.class";
public static final String PROP_JOB_STORE_USE_PROP = "org.quartz.jobStore.useProperties";
public static final String PROP_JOB_STORE_USE_PROP = "com.fr.third.v2.org.quartz.jobStore.useProperties";
public static final String PROP_DATASOURCE_PREFIX = "org.quartz.dataSource";
public static final String PROP_DATASOURCE_PREFIX = "com.fr.third.v2.org.quartz.dataSource";
public static final String PROP_CONNECTION_PROVIDER_CLASS = "connectionProvider.class";
@ -257,13 +257,13 @@ public class StdSchedulerFactory implements SchedulerFactory {
public static final String PROP_DATASOURCE_JNDI_CREDENTIALS = "java.naming.security.credentials";
public static final String PROP_PLUGIN_PREFIX = "org.quartz.plugin";
public static final String PROP_PLUGIN_PREFIX = "com.fr.third.v2.org.quartz.plugin";
public static final String PROP_PLUGIN_CLASS = "class";
public static final String PROP_JOB_LISTENER_PREFIX = "org.quartz.jobListener";
public static final String PROP_JOB_LISTENER_PREFIX = "com.fr.third.v2.org.quartz.jobListener";
public static final String PROP_TRIGGER_LISTENER_PREFIX = "org.quartz.triggerListener";
public static final String PROP_TRIGGER_LISTENER_PREFIX = "com.fr.third.v2.org.quartz.triggerListener";
public static final String PROP_LISTENER_CLASS = "class";
@ -271,15 +271,15 @@ public class StdSchedulerFactory implements SchedulerFactory {
public static final String AUTO_GENERATE_INSTANCE_ID = "AUTO";
public static final String PROP_THREAD_EXECUTOR = "org.quartz.threadExecutor";
public static final String PROP_THREAD_EXECUTOR = "com.fr.third.v2.org.quartz.threadExecutor";
public static final String PROP_THREAD_EXECUTOR_CLASS = "org.quartz.threadExecutor.class";
public static final String PROP_THREAD_EXECUTOR_CLASS = "com.fr.third.v2.org.quartz.threadExecutor.class";
public static final String SYSTEM_PROPERTY_AS_INSTANCE_ID = "SYS_PROP";
public static final String MANAGEMENT_REST_SERVICE_ENABLED = "org.quartz.managementRESTService.enabled";
public static final String MANAGEMENT_REST_SERVICE_ENABLED = "com.fr.third.v2.org.quartz.managementRESTService.enabled";
public static final String MANAGEMENT_REST_SERVICE_HOST_PORT = "org.quartz.managementRESTService.bind";
public static final String MANAGEMENT_REST_SERVICE_HOST_PORT = "com.fr.third.v2.org.quartz.managementRESTService.bind";
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
@ -633,12 +633,12 @@ public class StdSchedulerFactory implements SchedulerFactory {
autoId = true;
instanceIdGeneratorClass = cfg.getStringProperty(
PROP_SCHED_INSTANCE_ID_GENERATOR_CLASS,
"org.quartz.simpl.SimpleInstanceIdGenerator");
"com.fr.third.v2.org.quartz.simpl.SimpleInstanceIdGenerator");
}
else if (schedInstId.equals(SYSTEM_PROPERTY_AS_INSTANCE_ID)) {
autoId = true;
instanceIdGeneratorClass =
"org.quartz.simpl.SystemPropertyInstanceIdGenerator";
"com.fr.third.v2.org.quartz.simpl.SystemPropertyInstanceIdGenerator";
}
userTXLocation = cfg.getStringProperty(PROP_SCHED_USER_TX_URL,
@ -649,7 +649,7 @@ public class StdSchedulerFactory implements SchedulerFactory {
classLoadHelperClass = cfg.getStringProperty(
PROP_SCHED_CLASS_LOAD_HELPER_CLASS,
"org.quartz.simpl.CascadingClassLoadHelper");
"com.fr.third.v2.org.quartz.simpl.CascadingClassLoadHelper");
wrapJobInTx = cfg.getBooleanProperty(PROP_SCHED_WRAP_JOB_IN_USER_TX,
wrapJobInTx);
@ -659,7 +659,7 @@ public class StdSchedulerFactory implements SchedulerFactory {
idleWaitTime = cfg.getLongProperty(PROP_SCHED_IDLE_WAIT_TIME,
idleWaitTime);
if(idleWaitTime > -1 && idleWaitTime < 1000) {
throw new SchedulerException("org.quartz.scheduler.idleWaitTime of less than 1000ms is not legal.");
throw new SchedulerException("com.fr.third.v2.org.quartz.scheduler.idleWaitTime of less than 1000ms is not legal.");
}
dbFailureRetry = cfg.getLongProperty(PROP_SCHED_DB_FAILURE_RETRY_INTERVAL, dbFailureRetry);
@ -1218,7 +1218,7 @@ public class StdSchedulerFactory implements SchedulerFactory {
}
}
if (js.getClass().getName().startsWith("org.terracotta.quartz")) {
if (js.getClass().getName().startsWith("com.fr.third.v2.org.terracotta.quartz")) {
try {
String uuid = (String) js.getClass().getMethod("getUUID").invoke(js);
if(schedInstId.equals(DEFAULT_INSTANCE_ID)) {

2
fine-quartz/src/com/fr/third/v2/org/quartz/simpl/SystemPropertyInstanceIdGenerator.java
Unescape View File

@ -20,7 +20,7 @@ public class SystemPropertyInstanceIdGenerator implements InstanceIdGenerator {
/**
* System property to read the instanceId from
*/
public static final String SYSTEM_PROPERTY = "org.quartz.scheduler.instanceId";
public static final String SYSTEM_PROPERTY = "com.fr.third.v2.org.quartz.scheduler.instanceId";
private String prepend = null;
private String postpend = null;

2
fine-quartz/src/com/fr/third/v2/org/quartz/utils/DBConnectionManager.java
Unescape View File

@ -48,7 +48,7 @@ public class DBConnectionManager {
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
public static final String DB_PROPS_PREFIX = "org.quartz.db.";
public static final String DB_PROPS_PREFIX = "com.fr.third.v2.org.quartz.db.";
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

Write Preview
Loading…
Cancel
Save