blob: 7bc77e02c0103382baab9c7b37271cb41dd1bba4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
package org.apache.qpid.nclient.config;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.Collection;
import java.util.List;
import java.util.TreeMap;
import javax.security.sasl.SaslClientFactory;
import org.apache.commons.configuration.CombinedConfiguration;
import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.SystemConfiguration;
import org.apache.commons.configuration.XMLConfiguration;
import org.apache.log4j.Logger;
import org.apache.qpid.nclient.core.QpidConstants;
import org.apache.qpid.nclient.security.AMQPCallbackHandler;
/**
* Loads a properties file from classpath.
* These values can be overwritten using system properties
*/
public class ClientConfiguration extends CombinedConfiguration {
private static final Logger _logger = Logger.getLogger(ClientConfiguration.class);
private static ClientConfiguration _instance = new ClientConfiguration();
ClientConfiguration()
{
super();
addConfiguration(new SystemConfiguration());
try
{
XMLConfiguration config = new XMLConfiguration();
config.load(getInputStream());
addConfiguration(config);
}
catch (ConfigurationException e)
{
_logger.warn("Client Properties missing, using defaults",e);
}
}
public static ClientConfiguration get()
{
return _instance;
}
private InputStream getInputStream()
{
if (System.getProperty(QpidConstants.CONFIG_FILE_PATH) != null)
{
try
{
return new FileInputStream((String)System.getProperty(QpidConstants.CONFIG_FILE_PATH));
}
catch(Exception e)
{
return this.getClass().getResourceAsStream("client.xml");
}
}
else
{
return this.getClass().getResourceAsStream("client.xml");
}
}
public static void main(String[] args)
{
String key = QpidConstants.AMQP_SECURITY + "." +
QpidConstants.AMQP_SECURITY_SASL_CLIENT_FACTORY_TYPES + "." +
QpidConstants.AMQP_SECURITY_SASL_CLIENT_FACTORY;
TreeMap<String, Class<? extends SaslClientFactory>> factoriesToRegister =
new TreeMap<String, Class<? extends SaslClientFactory>>();
int index = ClientConfiguration.get().getMaxIndex(key);
for (int i=0; i<index+1;i++)
{
String mechanism = ClientConfiguration.get().getString(key + "(" + i + ")[@type]");
String className = ClientConfiguration.get().getString(key + "(" + i + ")" );
try
{
Class<?> clazz = Class.forName(className);
if (!(SaslClientFactory.class.isAssignableFrom(clazz)))
{
_logger.error("Class " + clazz + " does not implement " + SaslClientFactory.class + " - skipping");
continue;
}
factoriesToRegister.put(mechanism, (Class<? extends SaslClientFactory>) clazz);
}
catch (Exception ex)
{
_logger.error("Error instantiating SaslClientFactory calss " + className + " - skipping");
}
}
}
}
|
