1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.logging.log4j.core.net;
19
20 import java.util.Properties;
21 import java.util.concurrent.TimeUnit;
22
23 import javax.naming.Context;
24 import javax.naming.InitialContext;
25 import javax.naming.NamingException;
26
27 import org.apache.logging.log4j.core.appender.AbstractManager;
28 import org.apache.logging.log4j.core.appender.ManagerFactory;
29 import org.apache.logging.log4j.core.util.JndiCloser;
30
31
32
33
34
35
36 public class JndiManager extends AbstractManager {
37
38 private static final JndiManagerFactory FACTORY = new JndiManagerFactory();
39
40 private final Context context;
41
42 private JndiManager(final String name, final Context context) {
43 super(null, name);
44 this.context = context;
45 }
46
47
48
49
50
51
52 public static JndiManager getDefaultManager() {
53 return getManager(JndiManager.class.getName(), FACTORY, null);
54 }
55
56
57
58
59
60
61 public static JndiManager getDefaultManager(final String name) {
62 return getManager(name, FACTORY, null);
63 }
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78 public static JndiManager getJndiManager(final String initialContextFactoryName,
79 final String providerURL,
80 final String urlPkgPrefixes,
81 final String securityPrincipal,
82 final String securityCredentials,
83 final Properties additionalProperties) {
84 final String name = JndiManager.class.getName() + '@' + JndiManager.class.hashCode();
85 if (initialContextFactoryName == null) {
86 return getManager(name, FACTORY, null);
87 }
88 final Properties properties = new Properties();
89 properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, initialContextFactoryName);
90 if (providerURL != null) {
91 properties.setProperty(Context.PROVIDER_URL, providerURL);
92 } else {
93 LOGGER.warn("The JNDI InitialContextFactory class name [{}] was provided, but there was no associated " +
94 "provider URL. This is likely to cause problems.", initialContextFactoryName);
95 }
96 if (urlPkgPrefixes != null) {
97 properties.setProperty(Context.URL_PKG_PREFIXES, urlPkgPrefixes);
98 }
99 if (securityPrincipal != null) {
100 properties.setProperty(Context.SECURITY_PRINCIPAL, securityPrincipal);
101 if (securityCredentials != null) {
102 properties.setProperty(Context.SECURITY_CREDENTIALS, securityCredentials);
103 } else {
104 LOGGER.warn("A security principal [{}] was provided, but with no corresponding security credentials.",
105 securityPrincipal);
106 }
107 }
108 if (additionalProperties != null) {
109 properties.putAll(additionalProperties);
110 }
111 return getManager(name, FACTORY, properties);
112 }
113
114 @Override
115 protected boolean releaseSub(final long timeout, final TimeUnit timeUnit) {
116 return JndiCloser.closeSilently(this.context);
117 }
118
119
120
121
122
123
124
125
126
127 @SuppressWarnings("unchecked")
128 public <T> T lookup(final String name) throws NamingException {
129 return (T) this.context.lookup(name);
130 }
131
132 private static class JndiManagerFactory implements ManagerFactory<JndiManager, Properties> {
133
134 @Override
135 public JndiManager createManager(final String name, final Properties data) {
136 try {
137 return new JndiManager(name, new InitialContext(data));
138 } catch (final NamingException e) {
139 LOGGER.error("Error creating JNDI InitialContext.", e);
140 return null;
141 }
142 }
143 }
144 }