You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2012/01/13 06:25:15 UTC

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

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);
         }