You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2008/05/27 16:34:34 UTC
svn commit: r660531 - in
/incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler:
Scheduler.java impl/QuartzScheduler.java
Author: cziegeler
Date: Tue May 27 07:34:31 2008
New Revision: 660531
URL: http://svn.apache.org/viewvc?rev=660531&view=rev
Log:
Use constants for configuration properties.
Modified:
incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/Scheduler.java
incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/impl/QuartzScheduler.java
Modified: incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/Scheduler.java
URL: http://svn.apache.org/viewvc/incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/Scheduler.java?rev=660531&r1=660530&r2=660531&view=diff
==============================================================================
--- incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/Scheduler.java (original)
+++ incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/Scheduler.java Tue May 27 07:34:31 2008
@@ -29,6 +29,19 @@
*/
public interface Scheduler {
+ /** Name of the configuration property to define the period for a job. */
+ String PROPERTY_SCHEDULER_PERIOD = "scheduler.period";
+
+ /** Name of the configuration property to define the cron expression for a job. */
+ String PROPERTY_SCHEDULER_EXPRESSION = "scheduler.expression";
+
+ /** Name of the configuration property to define if the job can be run concurrently. */
+ String PROPERTY_SCHEDULER_CONCURRENT = "scheduler.concurrent";
+
+ /** Name of the configuration property to define the job name. */
+ String PROPERTY_SCHEDULER_NAME = "scheduler.name";
+
+
/**
* Schedule a time based job.
* Note that if a job with the same name has already beed added, the old job is cancelled and this new job replaces
Modified: incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/impl/QuartzScheduler.java
URL: http://svn.apache.org/viewvc/incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/impl/QuartzScheduler.java?rev=660531&r1=660530&r2=660531&view=diff
==============================================================================
--- incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/impl/QuartzScheduler.java (original)
+++ incubator/sling/trunk/commons/scheduler/src/main/java/org/apache/sling/commons/scheduler/impl/QuartzScheduler.java Tue May 27 07:34:31 2008
@@ -323,17 +323,17 @@
final Object job = this.context.locateService(type, ref);
if ( ref != null ) {
this.checkJob(job);
- String name = (String)ref.getProperty("scheduler.name");
+ String name = (String)ref.getProperty(Scheduler.PROPERTY_SCHEDULER_NAME);
if ( name == null ) {
name = (String)ref.getProperty(Constants.SERVICE_PID);
}
if ( name != null ) {
- final Boolean concurrent = (Boolean)ref.getProperty("scheduler.concurrent");
- final String expression = (String)ref.getProperty("scheduler.expression");
+ final Boolean concurrent = (Boolean)ref.getProperty(Scheduler.PROPERTY_SCHEDULER_CONCURRENT);
+ final String expression = (String)ref.getProperty(Scheduler.PROPERTY_SCHEDULER_EXPRESSION);
if ( expression != null ) {
this.addJob(name, job, null, expression, (concurrent != null ? concurrent : true));
} else {
- final Long period = (Long)ref.getProperty("scheduler.period");
+ final Long period = (Long)ref.getProperty(Scheduler.PROPERTY_SCHEDULER_PERIOD);
if ( period != null ) {
this.addPeriodicJob(name, job, null, period, (concurrent != null ? concurrent : true));
}
@@ -345,7 +345,7 @@
}
protected void unregister(ServiceReference ref) {
- String name = (String)ref.getProperty("scheduler.name");
+ String name = (String)ref.getProperty(Scheduler.PROPERTY_SCHEDULER_NAME);
if ( name == null ) {
name = (String)ref.getProperty(Constants.SERVICE_PID);
}