diff --git a/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java b/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java index ad5991c31e..d17b12d45b 100755 --- a/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java +++ b/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java @@ -53,6 +53,7 @@ public final class Scheduler { TimerTask ticket = TIMER_TASKS.remove(task); if (ticket != null) { ticket.cancel(); + CLOCK_DAEMON.purge();//remove cancelled TimerTasks } }