diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java index 3c2bccc424..f0c32d4212 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java @@ -79,6 +79,11 @@ abstract public class AbstractRegion implements Region { } public void stop() throws Exception { + for (Iterator i = destinations.values().iterator();i.hasNext();) { + Destination dest = (Destination)i.next(); + dest.stop(); + } + destinations.clear(); } public Destination addDestination(ConnectionContext context, ActiveMQDestination destination) throws Exception {