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