svn commit: r1230903 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors: ScheduledMessageProcessor.java forward/ScheduledMessageForwardingProcessor.java

[hiranya]

Author: hiranya
Date: Fri Jan 13 05:25:15 2012
New Revision: 1230903

URL: http://svn.apache.org/viewvc?rev=1230903&view=rev
Log:
Shutting down the schedulers initiated by the scheduled processors

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java?rev=1230903&r1=1230902&r2=1230903&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
 Fri Jan 13 05:25:15 2012
@@ -186,6 +186,7 @@ public abstract class ScheduledMessagePr
     public void destroy() {
         try {
             scheduler.deleteJob(name + 
"-trigger",SCHEDULED_MESSAGE_PROCESSOR_GROUP);
+            scheduler.shutdown(true);
         } catch (SchedulerException e) {
             log.error("Error while destroying the task " + e);
         }

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java?rev=1230903&r1=1230902&r2=1230903&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java
 Fri Jan 13 05:25:15 2012
@@ -33,7 +33,7 @@ import java.util.concurrent.atomic.Atomi
  * Redelivery processor is the Message processor which implements the Dead 
letter channel EIP
  * It will Time to time Redeliver the Messages to a given target.
  */
-public class ScheduledMessageForwardingProcessor extends 
ScheduledMessageProcessor{
+public class ScheduledMessageForwardingProcessor extends 
ScheduledMessageProcessor {
 
     public static final String BLOCKING_SENDER = "blocking.sender";
 
@@ -131,8 +131,9 @@ public class ScheduledMessageForwardingP
     @Override
     public void destroy() {
          try {
-            scheduler.deleteJob(name + "-forward job",
+             scheduler.deleteJob(name + "-forward job",
                     
ScheduledMessageProcessor.SCHEDULED_MESSAGE_PROCESSOR_GROUP);
+             scheduler.shutdown(true);
         } catch (SchedulerException e) {
             log.error("Error while destroying the task " + e);
         }