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 859c86b9c9..de794525d3 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 @@ -99,6 +99,13 @@ public abstract class AbstractTempRegion extends AbstractRegion { if (this.doCacheTempDestinations) { cachedDestinations.put(new CachedDestination(dest .getActiveMQDestination()), dest); + }else { + try { + dest.dispose(context); + dest.stop(); + } catch (Exception e) { + LOG.warn("Failed to dispose of " + dest, e); + } } }