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 29ed0778c0..69998e72c5 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 @@ -51,5 +51,9 @@ public final class Scheduler { TimerTask timerTask = new SchedulerTimerTask(task); CLOCK_DAEMON.schedule(timerTask, redeliveryDelay); } + + public static void shutdown() { + CLOCK_DAEMON.cancel(); + } }