mirror of https://github.com/apache/activemq.git
stop destinations when stoping a region
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@488958 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
f6972ec84a
commit
958c41a12b
|
@ -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 {
|
||||
|
|
Loading…
Reference in New Issue