[jboss-svn-commits] JBL Code SVN: r18164 - labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server.

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

Author: tcunning
Date: 2008-01-27 23:30:43 -0500 (Sun, 27 Jan 2008)
New Revision: 18164

Modified:
   labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFilerScheduler.java
Log:
bug:JBESB-1447
Delete jobs on destroy.


Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFilerScheduler.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFilerScheduler.java	2008-01-27 21:07:59 UTC (rev 18163)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/tools/console/management/src/main/java/org/jboss/soa/esb/monitoring/server/DataFilerScheduler.java	2008-01-28 04:30:43 UTC (rev 18164)
@@ -45,26 +45,42 @@
 	private static final Logger logger = Logger.getLogger(DataFilerScheduler.class);
 	private static final int DEFAULT_POLL_MINUTE_FREQ = 2;
 	
+	public Scheduler scheduler = null;
+	
 	private int pollMinuteFrequency = DEFAULT_POLL_MINUTE_FREQ;
 	
 	public int getPollMinuteFrequency() {
 		return pollMinuteFrequency;
 	}
 
+	public void create() throws Exception {
+		super.create();
+		SchedulerFactory schedulerFactory = new StdSchedulerFactory();
+		scheduler = schedulerFactory.getScheduler();
+	}
+	
+	public void destroy() {
+		super.destroy();
+		try {
+			scheduler.shutdown();
+			scheduler.deleteJob(DataFilerJob.JOB_GROUP, DataFilerJob.JOB_NAME);
+		} catch (SchedulerException e) {
+			logger.error("", e);
+		}
+	}
+	
 	public void setPollMinuteFrequency(int f_pollMinuteFrequency) {
 		pollMinuteFrequency = f_pollMinuteFrequency;
 		
 		long ctime = System.currentTimeMillis();
 		
 		try {
-			SchedulerFactory schedulerFactory = new StdSchedulerFactory();
-			Scheduler scheduler = schedulerFactory.getScheduler();
 			scheduler.deleteJob(DataFilerJob.JOB_GROUP, DataFilerJob.JOB_NAME);
 			
 			JobDetail jobDetail = new JobDetail(DataFilerJob.JOB_GROUP, DataFilerJob.JOB_NAME, DataFilerJob.class);
-                        
-                        final JobDataMap datamap = new JobDataMap() ;
-                        datamap.put(ClassLoader.class.getName(), Thread.currentThread().getContextClassLoader()) ;
+
+			final JobDataMap datamap = new JobDataMap() ;
+            datamap.put(ClassLoader.class.getName(), Thread.currentThread().getContextClassLoader()) ;
 			jobDetail.setJobDataMap(datamap) ;
 			
 			SimpleTrigger simpleTrigger = new SimpleTrigger(DataFilerJob.JOB_GROUP, DataFilerJob.JOB_NAME);
@@ -80,4 +96,7 @@
 			logger.error("", e);
 		}
 	}
+	
+	
+	
 }