set security on acceptor on start

hornetq · Nov 16, 2012 · ee9676b · ee9676b
1 parent 55f6e60
commit ee9676b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/hornetq-server/src/main/java/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java b/hornetq-server/src/main/java/org/hornetq/core/remoting/server/impl/RemotingServiceImpl.java
@@ -104,6 +104,8 @@ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycle
 
    private final Map<ProtocolType, ProtocolManager> protocolMap = new ConcurrentHashMap<ProtocolType, ProtocolManager>();
 
+   private HornetQPrincipal defaultInvmSecurityPrincipal;
+
    // Static --------------------------------------------------------
 
    // Constructors --------------------------------------------------
@@ -228,6 +230,11 @@ public ClassLoader run()
                                                        threadPool,
                                                        scheduledThreadPool);
 
+            if(defaultInvmSecurityPrincipal != null && acceptor.isUnsecurable())
+            {
+               acceptor.setDefaultHornetQPrincipal(defaultInvmSecurityPrincipal);
+            }
+
             acceptors.add(acceptor);
 
             if (managementService != null)
@@ -258,6 +265,7 @@ public ClassLoader run()
 
    public synchronized void allowInvmSecurityOverride(HornetQPrincipal principal)
    {
+      defaultInvmSecurityPrincipal = principal;
       for (Acceptor acceptor : acceptors)
       {
          if(acceptor.isUnsecurable())