mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607037 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
069a5676f1
commit
ea0cd012b1
|
@ -41,6 +41,7 @@ import org.apache.activemq.command.RemoveSubscriptionInfo;
|
|||
import org.apache.activemq.command.Response;
|
||||
import org.apache.activemq.filter.DestinationFilter;
|
||||
import org.apache.activemq.filter.DestinationMap;
|
||||
import org.apache.activemq.security.SecurityContext;
|
||||
import org.apache.activemq.thread.TaskRunnerFactory;
|
||||
import org.apache.activemq.usage.SystemUsage;
|
||||
import org.apache.commons.logging.Log;
|
||||
|
@ -81,7 +82,7 @@ public abstract class AbstractRegion implements Region {
|
|||
this.destinationFactory = destinationFactory;
|
||||
}
|
||||
|
||||
public void start() throws Exception {
|
||||
public final void start() throws Exception {
|
||||
started = true;
|
||||
|
||||
Set<ActiveMQDestination> inactiveDests = getInactiveDestinations();
|
||||
|
@ -90,6 +91,7 @@ public abstract class AbstractRegion implements Region {
|
|||
|
||||
ConnectionContext context = new ConnectionContext();
|
||||
context.setBroker(broker.getBrokerService().getBroker());
|
||||
context.setSecurityContext(SecurityContext.BROKER_SECURITY_CONTEXT);
|
||||
context.getBroker().addDestination(context, dest);
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue