From 51566104abd46722c73d71534e7576b5377d799c Mon Sep 17 00:00:00 2001 From: Timothy Bish Date: Tue, 25 Nov 2014 14:56:19 -0500 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-5447 shutdown the scheduled executer so that any scheduled tasks are canceled and removed on stop. --- .../org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java index 3c7c7cdf5d..aea8fa0b57 100755 --- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java +++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java @@ -55,6 +55,7 @@ import org.apache.activemq.util.FactoryFinder; import org.apache.activemq.util.IOExceptionSupport; import org.apache.activemq.util.LongSequenceGenerator; import org.apache.activemq.util.ServiceStopper; +import org.apache.activemq.util.ThreadPoolUtils; import org.apache.activemq.wireformat.WireFormat; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -336,6 +337,8 @@ public class JDBCPersistenceAdapter extends DataSourceServiceSupport implements cleanupTicket.cancel(true); cleanupTicket = null; } + + ThreadPoolUtils.shutdown(clockDaemon); } public void cleanup() {