cocoon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From un...@apache.org
Subject cvs commit: cocoon-2.1/src/blocks/cron/java/org/apache/cocoon/components/cron QuartzJobScheduler.java JobScheduler.java
Date Mon, 08 Mar 2004 13:43:42 GMT
unico       2004/03/08 05:43:42

  Modified:    src/blocks/cron/java/org/apache/cocoon/components/cron
                        QuartzJobScheduler.java JobScheduler.java
  Log:
  add method to schedule a periodic job directly
  
  Revision  Changes    Path
  1.10      +33 -2     cocoon-2.1/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java
  
  Index: QuartzJobScheduler.java
  ===================================================================
  RCS file: /home/cvs/cocoon-2.1/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -r1.9 -r1.10
  --- QuartzJobScheduler.java	5 Mar 2004 13:01:49 -0000	1.9
  +++ QuartzJobScheduler.java	8 Mar 2004 13:43:42 -0000	1.10
  @@ -224,6 +224,36 @@
   
           addJob(name, jobDataMap, timeEntry, canRunConcurrently, params, objects);
       }
  +    
  +    /**
  +     * Schedule a periodic job. The job is started the first time when the period has passed.
 Note that if a job with
  +     * the same name has already beed added it is overwritten.
  +     *
  +     * @param name the name of the job
  +     * @param job The job object itself. It must implement either CronJob, Runnable or
might also be an implementation
  +     *        specific class (i.e. org.quartz.Job)
  +     * @param period Every period seconds this job is started
  +     * @param canRunConcurrently whether this job can run even previous scheduled runs
are still running
  +     * @param params Additional Parameters to setup CronJob
  +     * @param objects A Map with additional object to setup CronJob
  +     */
  +    public void addPeriodicJob(String name, Object job, long period, boolean canRunConcurrently,
Parameters params,
  +                               Map objects)
  +    throws CascadingException {
  +        if (!(job instanceof CronJob) && !(job instanceof Runnable) &&
!(job instanceof Job)) {
  +            throw new CascadingException("Job object is neither an instance of " + CronJob.class.getName()
+ "," +
  +                                         Runnable.class.getName() + " nor " + Job.class.getName());
  +        }
  +        final JobDataMap jobDataMap = new JobDataMap();
  +        jobDataMap.put(DATA_MAP_OBJECT, job);
  +        
  +        final long ms = period * 1000;
  +        final SimpleTrigger timeEntry =
  +            new SimpleTrigger(name, DEFAULT_QUARTZ_JOB_GROUP, new Date(System.currentTimeMillis()
+ ms), null,
  +                              SimpleTrigger.REPEAT_INDEFINITELY, ms);
  +        
  +        addJob(name, jobDataMap, timeEntry, canRunConcurrently, params, objects);
  +    }
   
       /* (non-Javadoc)
        * @see org.apache.avalon.framework.configuration.Configurable#configure(org.apache.avalon.framework.configuration.Configuration)
  @@ -743,5 +773,6 @@
               }
           }
       }
  +
   
   }
  
  
  
  1.7       +17 -1     cocoon-2.1/src/blocks/cron/java/org/apache/cocoon/components/cron/JobScheduler.java
  
  Index: JobScheduler.java
  ===================================================================
  RCS file: /home/cvs/cocoon-2.1/src/blocks/cron/java/org/apache/cocoon/components/cron/JobScheduler.java,v
  retrieving revision 1.6
  retrieving revision 1.7
  diff -u -r1.6 -r1.7
  --- JobScheduler.java	5 Mar 2004 13:01:49 -0000	1.6
  +++ JobScheduler.java	8 Mar 2004 13:43:42 -0000	1.7
  @@ -113,6 +113,22 @@
       void addPeriodicJob(String name, String jobrole, long period, boolean canRunConcurrently,
Parameters params,
                           Map objects)
       throws CascadingException;
  +    
  +    /**
  +     * Schedule a periodic job. The job is started the first time when the period has passed.
 Note that if a job with
  +     * the same name has already beed added it is overwritten.
  +     *
  +     * @param name the name of the job
  +     * @param job The job object itself. It must implement either CronJob, Runnable or
might also be an implementation
  +     *        specific class (i.e. org.quartz.Job)
  +     * @param period Every period seconds this job is started
  +     * @param canRunConcurrently whether this job can run even previous scheduled runs
are still running
  +     * @param params Additional Parameters to setup CronJob
  +     * @param objects A Map with additional object to setup CronJob
  +     */
  +    void addPeriodicJob(String name, Object job, long period, boolean canRunConcurrently,
Parameters params,
  +                        Map objects)
  +    throws CascadingException;
   
       /**
        * Fire a job once immediately
  
  
  

Mime
View raw message