svn commit: r1100168 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java

[charith]

Author: charith
Date: Fri May  6 11:05:43 2011
New Revision: 1100168

URL: http://svn.apache.org/viewvc?rev=1100168&view=rev
Log:
adding cleaningup logic for Sampling processor

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java?rev=1100168&r1=1100167&r2=1100168&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/sampler/SamplingProcessor.java
 Fri May  6 11:05:43 2011
@@ -24,6 +24,7 @@ import org.apache.commons.logging.LogFac
 import org.apache.synapse.message.processors.AbstractMessageProcessor;
 import org.apache.synapse.message.processors.ScheduledMessageProcessor;
 import org.quartz.JobDetail;
+import org.quartz.SchedulerException;
 
 public class SamplingProcessor extends ScheduledMessageProcessor{
     private Log log = LogFactory.getLog(SamplingProcessor.class);
@@ -34,8 +35,19 @@ public class SamplingProcessor extends S
     @Override
     protected JobDetail getJobDetail() {
         JobDetail jobDetail = new JobDetail();
-        jobDetail.setName(messageStore + "-job");
+        jobDetail.setName(name + "-sampling-job");
         jobDetail.setJobClass(SamplingJob.class);
         return jobDetail;
     }
+
+    @Override
+    public void destroy() {
+         try {
+            scheduler.deleteJob(name + "-sampling-job",
+                    
ScheduledMessageProcessor.SCHEDULED_MESSAGE_PROCESSOR_GROUP);
+        } catch (SchedulerException e) {
+            log.error("Error while destroying the task " + e);
+        }
+        state = State.DESTROY;
+    }
 }