ConfigurationFileApplicationRegistry.java
01 /*
02  *
03  * Licensed to the Apache Software Foundation (ASF) under one
04  * or more contributor license agreements.  See the NOTICE file
05  * distributed with this work for additional information
06  * regarding copyright ownership.  The ASF licenses this file
07  * to you under the Apache License, Version 2.0 (the
08  * "License"); you may not use this file except in compliance
09  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  */
21 package org.apache.qpid.server.registry;
22 
23 import java.io.File;
24 
25 import org.apache.commons.configuration.ConfigurationException;
26 import org.apache.qpid.AMQException;
27 import org.apache.qpid.server.configuration.ServerConfiguration;
28 import org.apache.qpid.server.management.JMXManagedObjectRegistry;
29 import org.apache.qpid.server.management.NoopManagedObjectRegistry;
30 import org.apache.qpid.server.plugins.PluginManager;
31 import org.apache.qpid.server.security.access.ACLManager;
32 import org.apache.qpid.server.security.auth.database.ConfigurationFilePrincipalDatabaseManager;
33 import org.apache.qpid.server.security.auth.manager.PrincipalDatabaseAuthenticationManager;
34 import org.apache.qpid.server.virtualhost.VirtualHost;
35 import org.apache.qpid.server.virtualhost.VirtualHostRegistry;
36 
37 public class ConfigurationFileApplicationRegistry extends ApplicationRegistry
38 {
39 
40     public ConfigurationFileApplicationRegistry(File configurationURLthrows ConfigurationException
41     {
42         super(new ServerConfiguration(configurationURL));
43     }
44 
45     public void initialise() throws Exception
46     {
47         initialiseManagedObjectRegistry();
48 
49         _virtualHostRegistry = new VirtualHostRegistry();
50 
51         _pluginManager = new PluginManager(_configuration.getPluginDirectory());
52 
53         _accessManager = new ACLManager(_configuration.getSecurityConfiguration(), _pluginManager);
54         
55         _databaseManager = new ConfigurationFilePrincipalDatabaseManager(_configuration);
56 
57         _authenticationManager = new PrincipalDatabaseAuthenticationManager(null, null);
58 
59         _databaseManager.initialiseManagement(_configuration);
60 
61         _managedObjectRegistry.start();
62 
63         initialiseVirtualHosts();
64 
65     }
66 
67     private void initialiseVirtualHosts() throws Exception
68     {        
69         for (String name : _configuration.getVirtualHosts())
70         {
71             _virtualHostRegistry.registerVirtualHost(new VirtualHost(_configuration.getVirtualHostConfig(name)));
72         }
73         getVirtualHostRegistry().setDefaultVirtualHostName(_configuration.getDefaultVirtualHost());
74     }
75 
76     private void initialiseManagedObjectRegistry() throws AMQException
77     {
78         if (_configuration.getManagementEnabled())
79         {
80             _managedObjectRegistry = new JMXManagedObjectRegistry();
81         }
82         else
83         {
84             _managedObjectRegistry = new NoopManagedObjectRegistry();
85         }
86     }
87 }