diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java index de794525d3..c106b10779 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java @@ -59,7 +59,7 @@ public abstract class AbstractTempRegion extends AbstractRegion { this.doCacheTempDestinations=broker.getBrokerService().isCacheTempDestinations(); this.purgeTime = broker.getBrokerService().getTimeBeforePurgeTempDestinations(); if (this.doCacheTempDestinations) { - this.purgeTimer = new Timer(true); + this.purgeTimer = new Timer("ActiveMQ Temp destination purge timer", true); this.purgeTask = new TimerTask() { public void run() { doPurge(); diff --git a/activemq-jmdns_1.0/src/main/java/org/apache/activemq/jmdns/JmDNS.java b/activemq-jmdns_1.0/src/main/java/org/apache/activemq/jmdns/JmDNS.java index 8a808f30c3..db6dd6c52e 100644 --- a/activemq-jmdns_1.0/src/main/java/org/apache/activemq/jmdns/JmDNS.java +++ b/activemq-jmdns_1.0/src/main/java/org/apache/activemq/jmdns/JmDNS.java @@ -222,9 +222,7 @@ public class JmDNS services = new Hashtable(20); serviceTypes = new Hashtable(20); - // REMIND: If I could pass in a name for the Timer thread, - // I would pass 'JmDNS.Timer'. - timer = new Timer(); + timer = new Timer("JmDNS.Timer"); new RecordReaper().start(); shutdown = new Thread(new Shutdown(), "JmDNS.Shutdown"); Runtime.getRuntime().addShutdownHook(shutdown);