[jboss-cvs] jboss-seam/src/main/org/jboss/seam/async ...

[Gavin King]

  User: gavin   
  Date: 07/06/20 16:58:48

  Modified:    src/main/org/jboss/seam/async   QuartzDispatcher.java
  Added:       src/main/org/jboss/seam/async   QuartzTriggerHandle.java
  Log:
  dont use inner classes for apis ;-)
  
  Revision  Changes    Path
  1.4       +13 -30    jboss-seam/src/main/org/jboss/seam/async/QuartzDispatcher.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: QuartzDispatcher.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-seam/src/main/org/jboss/seam/async/QuartzDispatcher.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- QuartzDispatcher.java	20 Jun 2007 15:53:32 -0000	1.3
  +++ QuartzDispatcher.java	20 Jun 2007 20:58:48 -0000	1.4
  @@ -2,7 +2,6 @@
   
   import static org.jboss.seam.annotations.Install.BUILT_IN;
   
  -import java.io.Serializable;
   import java.rmi.server.UID;
   import java.util.Date;
   
  @@ -13,6 +12,7 @@
   import org.jboss.seam.annotations.Install;
   import org.jboss.seam.annotations.Name;
   import org.jboss.seam.annotations.Scope;
  +import org.jboss.seam.annotations.intercept.BypassInterceptors;
   import org.jboss.seam.intercept.InvocationContext;
   import org.jboss.seam.log.LogProvider;
   import org.jboss.seam.log.Logging;
  @@ -36,11 +36,13 @@
   @Scope(ScopeType.APPLICATION)
   @Name("org.jboss.seam.async.dispatcher")
   @Install(value=false, precedence=BUILT_IN)
  -public class QuartzDispatcher extends AbstractDispatcher<QuartzDispatcher.QuartzTriggerHandle, Schedule>
  + at BypassInterceptors
  +public class QuartzDispatcher extends AbstractDispatcher<QuartzTriggerHandle, Schedule>
   {
      
      private static final LogProvider log = Logging.getLogProvider(QuartzDispatcher.class);
  -   private static Scheduler scheduler;
  +   
  +   private Scheduler scheduler;
   
      @Create
      public void initScheduler() 
  @@ -225,7 +227,7 @@
         
      }
      
  -   public static class QuartzJob implements Job
  +   static class QuartzJob implements Job
      {
         private Asynchronous async;
         
  @@ -242,33 +244,14 @@
         }
      }
      
  -   public static class QuartzTriggerHandle implements Serializable
  -   {
  -      private String triggerName;
  -        
  -      public QuartzTriggerHandle(String triggerName) 
  -      {
  -         this.triggerName = triggerName; 
  -      }
  -
  -      public void cancel() throws SchedulerException
  +   public Scheduler getScheduler()
         {
  -         log.info("Cancel executing Quartz job");
  -         scheduler.unscheduleJob(triggerName, null);
  +      return scheduler;
         }
         
  -      public void pause() throws SchedulerException
  +   public static QuartzDispatcher instance()
         {
  -         log.info("Pause executing Quartz job");
  -         scheduler.pauseTrigger(triggerName, null);
  -         
  -      }
  -      
  -      public void resume() throws SchedulerException
  -      {
  -         log.info("Resume executing Quartz job");
  -         scheduler.resumeTrigger(triggerName, null);
  -      }
  +      return (QuartzDispatcher) AbstractDispatcher.instance();
      }
   
   }
  
  
  
  1.1      date: 2007/06/20 20:58:48;  author: gavin;  state: Exp;jboss-seam/src/main/org/jboss/seam/async/QuartzTriggerHandle.java
  
  Index: QuartzTriggerHandle.java
  ===================================================================
  package org.jboss.seam.async;
  
  import java.io.Serializable;
  
  import org.quartz.SchedulerException;
  
  /**
   * Provides control over the Quartz Job.
   * 
   * @author Michael Yuan
   *
   */
  public class QuartzTriggerHandle implements Serializable
  {
     private String triggerName;
       
     public QuartzTriggerHandle(String triggerName) 
     {
        this.triggerName = triggerName; 
     }
  
     public void cancel() throws SchedulerException
     {
        QuartzDispatcher.instance().getScheduler().unscheduleJob(triggerName, null);
     }
     
     public void pause() throws SchedulerException
     {
        QuartzDispatcher.instance().getScheduler().pauseTrigger(triggerName, null);  
     }
     
     public void resume() throws SchedulerException
     {
        QuartzDispatcher.instance().getScheduler().resumeTrigger(triggerName, null);
     }
  }