[Jboss-cvs] JBossAS SVN: r56970 - branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow

[jboss-cvs-commits at lists.jboss.org]

Author: weston.price at jboss.com
Date: 2006-09-19 09:57:28 -0400 (Tue, 19 Sep 2006)
New Revision: 56970

Modified:
   branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzActivationSpec.java
   branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzResourceAdapter.java
Log:
[JBAS-3640] Fixed discrepancy between JobDetail and Trigger for volatility parameter.
Also added durable and recoverable flags to ActivationSpec.

Modified: branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzActivationSpec.java
===================================================================
--- branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzActivationSpec.java	2006-09-19 13:49:36 UTC (rev 56969)
+++ branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzActivationSpec.java	2006-09-19 13:57:28 UTC (rev 56970)
@@ -27,9 +27,10 @@
 import javax.resource.ResourceException;
 import java.io.Serializable;
 
-/** The encapsulation of the mail folder endpoint specification
+/** The QuartzActivationSpec.
  *
- * @author Scott.Stark at jboss.org
+ * @author bill at jboss.org
+ * 
  * @version $Revision$
  */
 public class QuartzActivationSpec
@@ -56,9 +57,32 @@
    private String triggerGroup = "default";
    private String cronTrigger;
    private boolean stateful;
-
+   private boolean volatility;
+   private boolean durable;
+   private boolean recoverable;
+   
    //---- required ActivationSpec methods
 
+   public boolean getDurable()
+   {
+      return durable;
+   }
+
+   public void setDurable(boolean durable)
+   {
+      this.durable = durable;
+   }
+
+   public boolean getRecoverable()
+   {
+      return recoverable;
+   }
+
+   public void setRecoverable(boolean recoverable)
+   {
+      this.recoverable = recoverable;
+   }
+
    public void validate() throws InvalidPropertyException
    {
    }
@@ -137,8 +161,18 @@
 
    public String toString()
    {
-      return "jobName=" + jobName + ",jobGroup="+jobGroup+",triggerName="+triggerName+",triggerGroup="+triggerGroup+",cronTrigger="+cronTrigger;
+      return "jobName=" + jobName + ",jobGroup="+jobGroup+",triggerName="+triggerName+",triggerGroup="+triggerGroup+",cronTrigger="+cronTrigger + "volatility" + volatility + "durability" + durable + "recoverable" + recoverable;
    }
 
+   public boolean getVolatility()
+   {
+      return volatility;
+   }
 
+   public void setVolatility(boolean volatility)
+   {
+      this.volatility = volatility;
+   }
+
+
 }

Modified: branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzResourceAdapter.java
===================================================================
--- branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzResourceAdapter.java	2006-09-19 13:49:36 UTC (rev 56969)
+++ branches/Branch_4_0/connector/src/main/org/jboss/resource/adapter/quartz/inflow/QuartzResourceAdapter.java	2006-09-19 13:57:28 UTC (rev 56970)
@@ -35,8 +35,8 @@
 import javax.transaction.xa.XAResource;
 
 /**
- * Comment
- *
+ * The QuartzResourceAdapter. 
+ * 
  * @author <a href="mailto:bill at jboss.org">Bill Burke</a>
  * @version $Revision$
  */
@@ -48,8 +48,9 @@
 
    public void start(BootstrapContext ctx) throws ResourceAdapterInternalException
    {
+      
       log.info("start quartz!!!");
-      // First we must get a reference to a scheduler
+      
       SchedulerFactory sf = new StdSchedulerFactory();
       try
       {
@@ -90,7 +91,7 @@
 
       try
       {
-         JobDetail jobDetail = new JobDetail(quartzSpec.getJobName(), quartzSpec.getJobGroup(), clazz, true, false, false);
+         JobDetail jobDetail = new JobDetail(quartzSpec.getJobName(), quartzSpec.getJobGroup(), clazz, quartzSpec.getVolatility(), quartzSpec.getDurable(), quartzSpec.getRecoverable());
          jobDetail.getJobDataMap().setAllowsTransientData(true);
          jobDetail.getJobDataMap().put("endpointFactory", endpointFactory);
          log.debug("adding job: " + quartzSpec);